FromGoChannel
func FromGoChannel[T any](pipeline *Pipeline, channel <-chan T) *Channel[T]
FromGoChannel
creates a Channel
from a Go channel.
Example
channel := FromGoChannel(pipeline, goChannel)
func FromGoChannel[T any](pipeline *Pipeline, channel <-chan T) *Channel[T]
FromGoChannel
creates a Channel
from a Go channel.
channel := FromGoChannel(pipeline, goChannel)