Class: Nl::Async::Future::Sink

Inherits:

Object

• Object
• Nl::Async::Future::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.

• #succeed(value) ⇒ Object

Constructor Details

#initialize(mailbox) ⇒ Sink

Returns a new instance of Sink.

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

def initialize(mailbox)
  @mailbox = mailbox
end

Instance Method Details

#fail(exception) ⇒ Object

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

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

#finish ⇒ Object

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

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

#succeed(value) ⇒ Object

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

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