Skip to main content Link Search Menu Expand Document (external link)

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)