Open Sidebar
Close Sidebar
CrystalDoc.info
Source code
Shards.info
crystallum
v1.1.0
Top Level Namespace
Cl
Async
Job
RunningException
SafeLinkedList
Spawner
ThreadSafe
Debug
DS
BloomFilter
FIFO
FILO
LinkedList
Node
Queue
Stack
EmptyException
Hashing
Murmur
Miscs
WithSelf
Patterns
Publisher
Repository
Key
JSON
Any
Diff
Type
Built with Crystal 1.9.2
2023-10-08 14:54:56 UTC
module
Cl::Patterns::Publisher(O)
Direct including types
Cl::Async::Job(I, O)
Defined in:
patterns/publisher.cr
Instance Method Summary
#subscribe
(&block : O -> )
#unsubscribe
(block : Proc(O, Void))
Instance Method Detail
def
subscribe
(&block : O -> )
#
[
View source
]
def
unsubscribe
(block : Proc(O, Void))
#
[
View source
]