Documentation
¶
Overview ¶
Package chans は、チャネルに関するユーティリティが配置されています。
Index ¶
- func Bridge(done <-chan struct{}, chanCh <-chan <-chan interface{}) <-chan interface{}
- func Concat(done <-chan struct{}, chList ...<-chan interface{}) <-chan interface{}
- func FanIn(done <-chan struct{}, channels ...<-chan interface{}) <-chan interface{}
- func OrDone(done <-chan struct{}, in <-chan interface{}) <-chan interface{}
- func Repeat(done <-chan struct{}, values ...interface{}) <-chan interface{}
- func RepeatFn(done <-chan struct{}, fn func() interface{}) <-chan interface{}
- func Take(done <-chan struct{}, in <-chan interface{}, count int) <-chan interface{}
- func TakeWhile(done <-chan struct{}, in <-chan interface{}, value interface{}) <-chan interface{}
- func TakeWhileFn(done <-chan struct{}, in <-chan interface{}, fn func() interface{}) <-chan interface{}
- func Tee(done <-chan struct{}, in <-chan interface{}) (<-chan interface{}, <-chan interface{})
- func ToInt(done <-chan struct{}, in <-chan interface{}, failedValue int) <-chan int
- func ToInterfaceFromInt(ch <-chan int) <-chan interface{}
- func ToInterfaceFromString(ch <-chan string) <-chan interface{}
- func ToString(done <-chan struct{}, in <-chan interface{}, failedValue string) <-chan string
- func WhenAll(channels ...<-chan struct{}) <-chan struct{}
- func WhenAny(channels ...<-chan struct{}) <-chan struct{}
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Bridge ¶ added in v0.1.5
func Bridge(done <-chan struct{}, chanCh <-chan <-chan interface{}) <-chan interface{}
Bridge -- 指定されたチャネルのシーケンスを順に消費していく単一のチャネルを返します。
func Concat ¶ added in v0.1.7
func Concat(done <-chan struct{}, chList ...<-chan interface{}) <-chan interface{}
Concat -- 指定されたチャネルのシーケンスを順に消費していく単一のチャネルを返します。
func FanIn ¶ added in v0.1.5
func FanIn(done <-chan struct{}, channels ...<-chan interface{}) <-chan interface{}
FanIn -- 指定されたチャネルリストをファンインするチャネルを返します。
func OrDone ¶ added in v0.1.5
func OrDone(done <-chan struct{}, in <-chan interface{}) <-chan interface{}
OrDone -- 指定された終了チャネルと入力用チャネルのどちらかが閉じたら閉じるチャネルを返します。
func Repeat ¶ added in v0.1.5
func Repeat(done <-chan struct{}, values ...interface{}) <-chan interface{}
Repeat -- 指定した値を永遠と繰り返すチャネルを返します。
func RepeatFn ¶ added in v0.1.5
func RepeatFn(done <-chan struct{}, fn func() interface{}) <-chan interface{}
RepeatFn -- 指定した関数を永遠と繰り返し、その戻り値を返すチャネルを返します。
func Take ¶ added in v0.1.5
func Take(done <-chan struct{}, in <-chan interface{}, count int) <-chan interface{}
Take -- 指定した個数分、入力用チャネルから値を取得するチャネルを返します。
func TakeWhile ¶ added in v0.1.5
func TakeWhile(done <-chan struct{}, in <-chan interface{}, value interface{}) <-chan interface{}
TakeWhile -- 入力用チャネルから取得した値が指定した値と同一である間、値を取得し続けるチャネルを返します。
func TakeWhileFn ¶ added in v0.1.5
func TakeWhileFn(done <-chan struct{}, in <-chan interface{}, fn func() interface{}) <-chan interface{}
TakeWhileFn -- 入力用チャネルから取得した値が指定した関数の戻り値と同一である間、値を取得し続けるチャネルを返します。
func Tee ¶ added in v0.1.5
func Tee(done <-chan struct{}, in <-chan interface{}) (<-chan interface{}, <-chan interface{})
Tee -- Unix の tee コマンドのように一つの入力を２つに複製するチャネルを返します。
noinspection GoNilness
func ToInt ¶ added in v0.1.5
ToInt -- 入力用チャネルから値を取得し、数値に変換するチャネルを返します。
数値に変換することが出来なかった場合は、引数 failedValue を出力用チャネルに送ります。
func ToInterfaceFromInt ¶ added in v0.1.6
func ToInterfaceFromInt(ch <-chan int) <-chan interface{}
ToInterfaceFromInt -- chan int を chan interface{} に変換します。
func ToInterfaceFromString ¶ added in v0.1.6
func ToInterfaceFromString(ch <-chan string) <-chan interface{}
ToInterfaceFromString -- chan string を chan interface{} に変換します。
func ToString ¶ added in v0.1.5
ToString -- 入力用チャネルから値を取得し、文字列に変換するチャネルを返します。
文字列に変換することが出来なかった場合は、引数 failedValue を出力用チャネルに送ります。
Types ¶
This section is empty.
Source Files