src

Documentation

Overview

sender factory: JustValue

sender factory: LetError

sender factory: LetStoped

sender factory: LetValue

Index

• type OperationState
• type Sender
  • func Just[T any](v T) Sender[T]
  • func JustError[T any](err error) Sender[T]
  • func JustStoped[T any]() Sender[T]
  • func LetError[T any](s Sender[T], f func(context.Context, error, sr.Receiver[T])) Sender[T]
  • func LetStoped[T any](s Sender[T], f func(context.Context, sr.Receiver[T])) Sender[T]
  • func LetValue[T any, R any](s Sender[T], f func(context.Context, T, sr.Receiver[R])) Sender[R]
  • func NonCtx[T any](s sr.Sender[T]) Sender[T]
  • func Split[T any](s Sender[T]) Sender[T]
  • func StopedAsError[T any](s Sender[T], err error) Sender[T]
  • func Then[From any, To any](s Sender[From], f func(context.Context, From) To) Sender[To]
  • func WhenAll2[T1, T2 any](s1 Sender[T1], s2 Sender[T2]) Sender[lo.Tuple2[T1, T2]]
  • func WhenAll3[T1, T2, T3 any](s1 Sender[T1], s2 Sender[T2], s3 Sender[T3]) Sender[lo.Tuple3[T1, T2, T3]]
  • func WhenAll4[T1, T2, T3, T4 any](s1 Sender[T1], s2 Sender[T2], s3 Sender[T3], s4 Sender[T4]) Sender[lo.Tuple4[T1, T2, T3, T4]]
  • func WhenAll5[T1, T2, T3, T4, T5 any](s1 Sender[T1], s2 Sender[T2], s3 Sender[T3], s4 Sender[T4], s5 Sender[T5]) Sender[lo.Tuple5[T1, T2, T3, T4, T5]]
  • func WhenAll6[T1, T2, T3, T4, T5, T6 any](s1 Sender[T1], s2 Sender[T2], s3 Sender[T3], s4 Sender[T4], s5 Sender[T5], ...) Sender[lo.Tuple6[T1, T2, T3, T4, T5, T6]]
  • func WhenAll7[T1, T2, T3, T4, T5, T6, T7 any](s1 Sender[T1], s2 Sender[T2], s3 Sender[T3], s4 Sender[T4], s5 Sender[T5], ...) Sender[lo.Tuple7[T1, T2, T3, T4, T5, T6, T7]]
  • func WhenAll8[T1, T2, T3, T4, T5, T6, T7, T8 any](s1 Sender[T1], s2 Sender[T2], s3 Sender[T3], s4 Sender[T4], s5 Sender[T5], ...) Sender[lo.Tuple8[T1, T2, T3, T4, T5, T6, T7, T8]]
  • func WhenAll9[T1, T2, T3, T4, T5, T6, T7, T8, T9 any](s1 Sender[T1], s2 Sender[T2], s3 Sender[T3], s4 Sender[T4], s5 Sender[T5], ...) Sender[lo.Tuple9[T1, T2, T3, T4, T5, T6, T7, T8, T9]]
  • func WhenAllSlice[T any](ss ...Sender[T]) Sender[[]T]

Types

type OperationState

type OperationState interface {
	Start(context.Context)
}

type Sender

type Sender[T any] interface {
	Tag() sr.SenderTag
	Connect(sr.Receiver[T]) OperationState
}

func Just

func Just[T any](v T) Sender[T]

func JustError

func JustError[T any](err error) Sender[T]

func JustStoped

func JustStoped[T any]() Sender[T]

func LetError

func LetError[T any](s Sender[T], f func(context.Context, error, sr.Receiver[T])) Sender[T]

func LetStoped

func LetStoped[T any](s Sender[T], f func(context.Context, sr.Receiver[T])) Sender[T]

func LetValue

func LetValue[T any, R any](s Sender[T], f func(context.Context, T, sr.Receiver[R])) Sender[R]

func NonCtx

func NonCtx[T any](s sr.Sender[T]) Sender[T]

func Split

func Split[T any](s Sender[T]) Sender[T]

func StopedAsError

func StopedAsError[T any](s Sender[T], err error) Sender[T]

func Then

func Then[From any, To any](s Sender[From], f func(context.Context, From) To) Sender[To]

func WhenAll2

func WhenAll2[T1, T2 any](s1 Sender[T1], s2 Sender[T2]) Sender[lo.Tuple2[T1, T2]]

func WhenAll3

func WhenAll3[T1, T2, T3 any](s1 Sender[T1], s2 Sender[T2], s3 Sender[T3]) Sender[lo.Tuple3[T1, T2, T3]]

func WhenAll4

func WhenAll4[T1, T2, T3, T4 any](s1 Sender[T1], s2 Sender[T2], s3 Sender[T3], s4 Sender[T4]) Sender[lo.Tuple4[T1, T2, T3, T4]]

func WhenAll5

func WhenAll5[T1, T2, T3, T4, T5 any](s1 Sender[T1], s2 Sender[T2], s3 Sender[T3], s4 Sender[T4], s5 Sender[T5]) Sender[lo.Tuple5[T1, T2, T3, T4, T5]]

func WhenAll6

func WhenAll6[T1, T2, T3, T4, T5, T6 any](s1 Sender[T1], s2 Sender[T2], s3 Sender[T3], s4 Sender[T4], s5 Sender[T5], s6 Sender[T6]) Sender[lo.Tuple6[T1, T2, T3, T4, T5, T6]]

func WhenAll7

func WhenAll7[T1, T2, T3, T4, T5, T6, T7 any](s1 Sender[T1], s2 Sender[T2], s3 Sender[T3], s4 Sender[T4], s5 Sender[T5], s6 Sender[T6], s7 Sender[T7]) Sender[lo.Tuple7[T1, T2, T3, T4, T5, T6, T7]]

func WhenAll8

func WhenAll8[T1, T2, T3, T4, T5, T6, T7, T8 any](s1 Sender[T1], s2 Sender[T2], s3 Sender[T3], s4 Sender[T4], s5 Sender[T5], s6 Sender[T6], s7 Sender[T7], s8 Sender[T8]) Sender[lo.Tuple8[T1, T2, T3, T4, T5, T6, T7, T8]]

func WhenAll9

func WhenAll9[T1, T2, T3, T4, T5, T6, T7, T8, T9 any](s1 Sender[T1], s2 Sender[T2], s3 Sender[T3], s4 Sender[T4], s5 Sender[T5], s6 Sender[T6], s7 Sender[T7], s8 Sender[T8], s9 Sender[T9]) Sender[lo.Tuple9[T1, T2, T3, T4, T5, T6, T7, T8, T9]]

func WhenAllSlice

func WhenAllSlice[T any](ss ...Sender[T]) Sender[[]T]