tursom/GoCollections
1
0
Fork 0
mirror of https://github.com/tursom/GoCollections.git synced 2025-03-13 17:00:18 +08:00
Code Issues Packages Projects Releases Wiki Activity

add ConvChannel

Browse Source
This commit is contained in:
tursom 2022-11-25 18:33:21 +08:00
parent 083f5271fe
commit 5c72e98873
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lang/ConvChannel.go
View File

@ -35,15 +35,15 @@ func ConvChannel[T1, T2 any](c1 Channel[T1], recvConv func(T1) T2, sendConv func
return &convChannel[T1, T2]{c1, recvConv, sendConv}
}
func ConvSendChannel[T1, T2 any](c1 Channel[T1], sendConv func(T2) T1) SendChannelProxy[T2, T1] {
func ConvSendChannel[T1, T2 any](c1 SendChannel[T1], sendConv func(T2) T1) SendChannelProxy[T2, T1] {
return &convSendChannel[T1, T2]{c1, sendConv}
}
func ConvReceiveChannel[T1, T2 any](c1 Channel[T1], recvConv func(T1) T2) ReceiveChannelProxy[T2, T1] {
func ConvReceiveChannel[T1, T2 any](c1 ReceiveChannel[T1], recvConv func(T1) T2) ReceiveChannelProxy[T2, T1] {
return &convReceiveChannel[T1, T2]{c1, recvConv}
}
func FilterReceiveChannel[T any](c1 Channel[T], filter func(T) bool) ReceiveChannelProxy[T, T] {
func FilterReceiveChannel[T any](c1 ReceiveChannel[T], filter func(T) bool) ReceiveChannelProxy[T, T] {
return &filterReceiveChannel[T]{c1, filter}
}