Module: Hx

Defined in:

lib/interop/channel.rb,
lib/interop.rb,
lib/interop/pipe.rb,
lib/interop/error.rb,
lib/interop/reader.rb,
lib/interop/writer.rb,
lib/interop/headers.rb,
lib/interop/message.rb,
lib/interop/version.rb,
lib/interop/rpc/base.rb,
lib/interop/marshaler.rb,
lib/interop/rpc/magic.rb,
lib/interop/connection.rb,
lib/interop/middleware.rb,
lib/interop/rpc/client.rb,
lib/interop/rpc/server.rb,
lib/interop/task_group.rb,
lib/interop/interceptor.rb,
lib/interop/content_type.rb,
lib/interop/content_types.rb,
lib/interop/reader_writer.rb,
lib/interop/stream_reader.rb,
lib/interop/stream_writer.rb,
lib/interop/rpc/controller.rb,
lib/interop/rpc/dispatcher.rb,
lib/interop/stream_adapter.rb,
lib/interop/interceptor/base.rb,
lib/interop/interceptor/read.rb,
lib/interop/interceptor/write.rb

Overview

TODO: the only reason this class exists is because SizedQueue doesn’t allow a zero max.

Figure out a way to block on the first push to a SizedQueue, and this messy situation
can go away for good. In the meantime, a buffered version of this class is like a
SizedQueue already, so that functionality can be removed.

Defined Under Namespace

Modules: Interop