MCPcopy Create free account
hub / github.com/eapache/channels / In

Method In

channels.go:54–54  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

52// implement the Buffer interface.
53type SimpleInChannel interface {
54 In() chan<- interface{} // The writeable end of the channel.
55 Close() // Closes the channel. It is an error to write to In() after calling Close().
56}
57

Callers 15

pipeFunction · 0.65
multiplexFunction · 0.65
teeFunction · 0.65
distributeFunction · 0.65
TestOverflowingChannelFunction · 0.65
TestRingChannelFunction · 0.65
testBatchesFunction · 0.65
TestSharedBufferMultipleFunction · 0.65
ExampleSharedBufferFunction · 0.65
testChannelFunction · 0.65

Implementers 8

InfiniteChannelinfinite_channel.go
OverflowingChanneloverflowing_channel.go
DeadChannelnative_channel.go
sharedBufferChannelshared_buffer.go
RingChannelring_channel.go
ResizableChannelresizable_channel.go
BatchingChannelbatching_channel.go
BlackHoleblack_hole.go

Calls

no outgoing calls

Tested by 12

TestOverflowingChannelFunction · 0.52
TestRingChannelFunction · 0.52
testBatchesFunction · 0.52
TestSharedBufferMultipleFunction · 0.52
ExampleSharedBufferFunction · 0.52
testChannelFunction · 0.52
testChannelPairFunction · 0.52
testMultiplexFunction · 0.52
ExampleChannelFunction · 0.52