Class: Hx::Interop::Interceptor::Read

Inherits:

Base

• Object
• Base
• Hx::Interop::Interceptor::Read

Includes:

Reader

Defined in:

lib/interop/interceptor/read.rb

Overview

Intercept reads TODO: consider a background-processed version (like the Go version)

Instance Method Summary

• #initialize(reader, &block) ⇒ Read constructor

  A new instance of Read.

Methods included from Reader

new, #read, #read_all

Constructor Details

#initialize(reader, &block) ⇒ Read

Returns a new instance of Read.

Parameters:

• reader (Reader)

# File 'lib/interop/interceptor/read.rb', line 13

def initialize(reader, &block)
  super
  @queue = []
  @mutex = Mutex.new
end