class Cute::BufferSink(T)

Overview

Sink buffering incoming data up to a specified size, emitting all at once when specified count has been reached.

See Sink for documentation on the usage.

Defined in:

cute/buffer_sink.cr

Constructors

Instance Method Summary

Instance methods inherited from class Cute::Sink(T)

emit(data : Array(T)) : Nil emit, hit_count : Int32 hit_count, name : String name, new_channel : Tuple(Channel(Array(T)), Cute::ConnectionHandle) new_channel, notify(data : T) notify, on(&block : Proc(Array(T), Nil)) : Cute::ConnectionHandle
on(sink : Cute::Sink(U)) forall U on, stop! stop!

Constructor methods inherited from class Cute::Sink(T)

new new

Instance methods inherited from class Cute::Signal

disconnect(handler_hash)
disconnect disconnect, name : String | Nil name, wait wait

Constructor Detail

def self.new(size : Int32) #

[View source]

Instance Method Detail

def size : Int32 #

Size of the buffer


[View source]
def size=(size : Int32) #

Size of the buffer


[View source]