Components
Namespace: FsShelter.Extras
Nested types and modules
| Type | Description |
| Signal | Represent a DU case as a signal Signals are more about the fact that something happened than the data they carry. They can be used to implement logic gates (for an E to happen, A,B,C and D have to happen first). |
| Module | Description |
| Bolt | |
| Consumer | |
| Spout |
Functions and values
| Function or value | Description |
ackerOfConsumer
Signature: (type) -> (type)
Type parameters: '?7666 |
|
createAggregationBolt
Signature: ('?7686 -> '?7687 -> '?7688 -> Async<'?7689>) -> (('?7686 -> '?7689) -> '?7690) * '?7688 * '?7687 -> '?7690
Type parameters: '?7686, '?7687, '?7688, '?7689, '?7690 |
|
createExchangeBolt
Signature: ('?7692 -> '?7693 * string) -> '?7692 * (string -> (type)) -> unit
Type parameters: '?7692, '?7693 |
|
createJoinBolt
Signature: ('?7680 -> '?7681) -> ('?7680 -> '?7682 option -> bool * '?7683) -> ('?7681 -> '?7680 -> '?7683 -> '?7684) -> '?7680 * ('?7684 -> unit) -> unit
Type parameters: '?7680, '?7681, '?7682, '?7683, '?7684 |
|
createJoinBoltWith
Signature: (type) * int -> ('?7674 -> '?7675) -> ('?7674 -> '?7676 option -> bool * '?7677) -> ('?7675 -> '?7674 -> '?7677 -> '?7678) -> '?7674 * ('?7678 -> unit) -> unit
Type parameters: '?7674, '?7675, '?7676, '?7677, '?7678 |
|
createNotifierBolt
Signature: ('?7671 -> '?7672) -> '?7671 * (type) -> unit
Type parameters: '?7671, '?7672 |
|
createPersistBolt
Signature: ('?7655 -> '?7656 -> Async<'?7657>) -> (('?7655 -> Async<'?7657>) -> '?7658) * '?7656 -> '?7658
Type parameters: '?7655, '?7656, '?7657, '?7658 |
|
createQueueSpout
Signature: ('?7668 -> '?7669) -> (type) -> (string * '?7669) option
Type parameters: '?7668, '?7669 |
|
createTransformBolt
Signature: ('?7660 -> '?7661 -> Async<'?7662>) -> (('?7660 -> Async<unit>) -> '?7664) * '?7661 * ('?7663 -> unit) -> '?7664
Type parameters: '?7660, '?7661, '?7662, '?7663, '?7664 |
|
signalAggregator
Signature: bigint list -> 't -> bigint list option -> bool * bigint list
Type parameters: 't |
|
