JetChannel

Example

julia> using NATS
julia> using NATS.JetStream
julia> nc = NATS.connect()NATS.Connection(unnamed cluster, CONNECTED, 0 subs, 0 unsubs)
julia> ch = JetChannel{String}(nc, "example_jetstream_channel");
julia> put!(ch, "test");
julia> take!(ch)"test"
julia> t = @async take!(ch)Task (runnable) @0x00007f3580418330
julia> sleep(1)
julia> istaskdone(t)false
julia> put!(ch, "some value");
julia> sleep(0.1)
julia> t.result"some value"
julia> destroy!(ch)NATS.JetStream.ApiResult(true)