Class: Nl::Async::Stream::Sink

Inherits:

Object

• Object
• Nl::Async::Stream::Sink

Defined in:

nl/lib/nl/async/operation.rb

Instance Method Summary

• #fail(exception) ⇒ Object
• #finish ⇒ Object
• #initialize(mailbox) ⇒ Sink constructor

  A new instance of Sink.

• #push(value) ⇒ Object

Constructor Details

#initialize(mailbox) ⇒ Sink

Returns a new instance of Sink.

# File 'nl/lib/nl/async/operation.rb', line 267

def initialize(mailbox)
  @mailbox = mailbox
end

Instance Method Details

#fail(exception) ⇒ Object

# File 'nl/lib/nl/async/operation.rb', line 273

def fail(exception) = @mailbox.push_terminal(Events::Error.new(exception))

#finish ⇒ Object

# File 'nl/lib/nl/async/operation.rb', line 272

def finish = @mailbox.push_terminal(Events::Done.new)

#push(value) ⇒ Object

# File 'nl/lib/nl/async/operation.rb', line 271

def push(value) = @mailbox.push(Events::Item.new(value))