class Zap::Utils::Concurrent::Pipeline

Defined in:

utils/concurrent/pipeline.cr

Constructors

Class Method Summary

Instance Method Summary

Instance methods inherited from class Object

or(other : T) : T | self forall T or, pipe(&) pipe

Constructor Detail

def self.new #

[View source]

Class Method Detail

def self.wrap(*, force_wait = false, &block : Pipeline -> ) #

[View source]

Instance Method Detail

def await(*, force_wait = false) #

[View source]
def check_max_fibers(&) #

[View source]
def counter : Atomic(Int32) #

[View source]
def process(&block) #

[View source]
def reset #

[View source]
def set_concurrency(max_fibers : Int32 | Nil) #

[View source]
def wrap(&block : self -> ) #

[View source]