Open Sidebar
Close Sidebar
CrystalDoc.info
Source code
Shards.info
concurrent
v0.5.0
Array
Channel
Concurrent
CountDownLatch
Error
CountExceeded
Internal
CyclicBarrier
Error
Broken
Semaphore
Stream
Base
NilBlock
Batch
Destination
Error
Misuse
ErrorHandling
Errors
Map
Run
Scope
Select
SendRecv
Serial
Source
Tee
Wait
Enumerable
Built with Crystal 1.9.2
2023-10-08 08:07:00 UTC
abstract class
Concurrent::Stream::Base
Concurrent::Stream::Base
Reference
Object
Direct Known Subclasses
Concurrent::Stream::Destination(E)
Concurrent::Stream::SendRecv(B, V, E, SC)
Defined in:
concurrent/stream.cr
Constructors
.new
(*, fibers : Int32, parent : Concurrent::Stream::Base | Nil)
Instance Method Summary
#close
: Nil
Constructor Detail
def self.
new
(*, fibers : Int32, parent :
Concurrent::Stream::Base
| Nil)
#
[
View source
]
Instance Method Detail
def
close
: Nil
#
[
View source
]