Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/Effect-TS/effect
/ take
Method
take
packages/effect/src/internal/pubsub.ts:1704–1704 ·
view source on GitHub ↗
()
Source
from the content-addressed store, hash-verified
1702
1703
interface
ReplayWindow<A> {
1704
take(): A | undefined
1705
takeN(n: number): Chunk.Chunk<A>
1706
takeAll(): Chunk.Chunk<A>
1707
readonly remaining: number
Callers
15
takeN
Method · 0.65
take
Method · 0.65
PoolImpl
Class · 0.65
shutdown
Method · 0.65
take
Method · 0.65
stream.ts
File · 0.65
_async
Function · 0.65
asyncEffect
Function · 0.65
asyncPush
Function · 0.65
asyncScoped
Function · 0.65
bufferUnbounded
Function · 0.65
consumer
Function · 0.65
Implementers
3
QueueSpy
packages/effect/test/Sink/constructors
ReplayWindowImpl
packages/effect/src/internal/pubsub.ts
MapDequeue
packages/effect/src/internal/groupBy.t
Calls
no outgoing calls
Tested by
no test coverage detected