MCPcopy Create free account

hub / github.com/CodeForBreakfast/eventsourcing / functions

Functions1,511 in github.com/CodeForBreakfast/eventsourcing

⨍ Functions 1,511◇ Types & classes 208
↓ 2 callersFunctiondropEventsFromStream
(count: number)
packages/eventsourcing-store-inmemory/src/lib/inMemoryEventStore.ts:17
↓ 2 callersFunctiondropEventsFromStream
(count: number)
packages/eventsourcing-store-filesystem/src/lib/fileSystemEventStore.ts:7
↓ 2 callersFunctionensureEventStream
(streamId: EventStreamId)
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:182
↓ 2 callersFunctionensurePubSubExists
( streamId: EventStreamId, state: SynchronizedRef.SynchronizedRef<FileSystemStoreState<V>> )
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:220
↓ 2 callersFunctionexpectSome
(option: Option.Option<A>)
packages/bun-test-effect/src/effect-assertions.ts:6
↓ 2 callersFunctionextractSpanContext
()
packages/eventsourcing-protocol/src/lib/server-protocol.ts:152
↓ 2 callersFunctionextractSpanContext
()
packages/eventsourcing-protocol/src/lib/protocol.ts:310
↓ 2 callersFunctionfailWithReadError
(streamId: string | undefined)
packages/eventsourcing-store/src/lib/services.test.ts:78
↓ 2 callersFunctionfilterDependencyOnlyPackageJsonFiles
(files: readonly string[], baseBranch: string)
scripts/validate-changesets.ts:430
↓ 2 callersFunctionfilterOutPrivatePackageFiles
( changedFiles: readonly string[], privatePackagePaths: readonly string[] )
scripts/validate-changesets.ts:335
↓ 2 callersFunctionfindEventStreamOrDie
( eventStreamsById: HashMap.HashMap<EventStreamId, EventStream<V>>, streamId: EventStreamId )
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:224
↓ 2 callersFunctionforkAllEventsSubscription
(store: EventStore<string>, count: number)
packages/eventsourcing-store-postgres/src/bridge.integration.test.ts:53
↓ 2 callersFunctiongetClientConnectionState
(client: { readonly connectionState: Stream.Stream<ConnectionState>; })
packages/eventsourcing-transport-inmemory/src/tests/integration/client-server.test.ts:209
↓ 2 callersFunctiongetDependencies
(pkgJson: { readonly dependencies?: Record<string, string> })
scripts/auto-generate-dependency-changeset.ts:85
↓ 2 callersFunctiongetEventFilePath
(streamDir: string, eventNumber: number, path: Path.Path)
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:68
↓ 2 callersFunctiongetPrivatePackagePaths
( packages: readonly PackageInternal[], rootDir: string )
scripts/validate-changesets.ts:323
↓ 2 callersFunctionhandleCommand
( event: TEvent, buildCommand: ( state: Readonly<AggregateState<TodoListState>> ) => Effect.Effect<R
examples/todo-app/src/infrastructure/processManager.ts:59
↓ 2 callersFunctionhandleConditional
( events: Readonly<ReadonlyArray<unknown>>, whenTrue: Readonly<Effect.Effect<void, E, R>>, whenFalse: Re
examples/todo-app/src/cli.ts:63
↓ 2 callersFunctionhandleNoCodeChanges
( changedFiles: readonly string[], changesets: readonly ChangesetInfoInternal[] )
scripts/validate-changesets.ts:893
↓ 2 callersFunctionisBooleanExpression
(node, sourceCode)
packages/eslint-effect/src/rules/prefer-effect-if-over-match-boolean.js:69
↓ 2 callersFunctionisCallExpression
(node)
packages/eslint-effect/src/rules/prefer-match-over-ternary.js:48
↓ 2 callersFunctionisEffectConstructor
(node)
packages/eslint-effect/src/rules/prefer-match-over-ternary.js:132
↓ 2 callersFunctionisMapCall
(node)
packages/eslint-effect/src/rules/prefer-as.js:32
↓ 2 callersFunctionisOptionSome
(node)
packages/eslint-effect/src/rules/utils.js:67
↓ 2 callersFunctionisSimpleLiteralEquality
(condition)
packages/eslint-effect/src/rules/prefer-match-over-ternary.js:52
↓ 2 callersFunctionisVoidReturn
(arrowFunc)
packages/eslint-effect/src/rules/utils.js:1
↓ 2 callersFunctionisVoidReturningFunction
(node)
packages/eslint-effect/src/rules/utils.js:77
↓ 2 callersFunctionjoinToPath
(basePath: string, ...segments: ReadonlyArray<string>)
scripts/validate-publish.ts:15
↓ 2 callersFunctionloadProjection
( eventstoreTag: ReadonlyDeep< Context.Tag<ProjectionEventStore<TEvent>, ProjectionEventStore<TEvent
packages/eventsourcing-projections/src/lib/projection.ts:113
↓ 2 callersFunctionlogError
(message: string, error: unknown)
packages/eslint-effect/test/currying-examples.ts:11
↓ 2 callersFunctionmake
()
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:320
↓ 2 callersFunctionmakeChannelName
(streamId: EventStreamId)
packages/eventsourcing-store-postgres/src/notificationListener.ts:21
↓ 2 callersFunctionmakeEventBusLayer
()
packages/eventsourcing-server/src/lib/eventBus.test.ts:50
↓ 2 callersFunctionmakeIt
()
packages/bun-test-effect/src/internal/internal.ts:211
↓ 2 callersFunctionmakeMethods
()
packages/bun-test-effect/src/internal/internal.ts:267
↓ 2 callersFunctionmakeMockTransport
()
packages/eventsourcing-testing-contracts/src/lib/test-utilities.ts:177
↓ 2 callersFunctionmakeTestStoreLayer
()
packages/eventsourcing-server/src/lib/eventBus.test.ts:40
↓ 2 callersFunctionprocessData
(prefix: string, suffix: string, data: string)
packages/eslint-effect/test/currying-examples.ts:35
↓ 2 callersFunctionprocessData
(prefix: string, suffix: string, data: string)
packages/eslint-effect/test/suggest-currying-opportunity.test.ts:11
↓ 2 callersFunctionprocessDirectory
( currentDir: string, files: readonly string[] = [] )
scripts/validate-markdown-examples.ts:269
↓ 2 callersFunctionprocessValue
(value: string)
packages/eslint-effect/test/prefer-match-over-ternary.test.ts:113
↓ 2 callersFunctionpublishEventsToStream
(pubsub: PubSub.PubSub<V>, newEvents: Chunk.Chunk<V>)
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:56
↓ 2 callersFunctionpublishEventsToStream
( pubsub: PubSub.PubSub<V>, events: Chunk.Chunk<V> )
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:226
↓ 2 callersFunctionpublishMessageToClient
(clientState: ReadonlyDeep<ClientState>)
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:90
↓ 2 callersFunctionpublishWithConnectionCheck
( clientState: ReadonlyDeep<InMemoryClientState>, targetQueue: ReadonlyDeep<Queue.Queue<TransportMessa
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:130
↓ 2 callersFunctionreadPackagesDir
( directoryName: string, [fs, path, rootDir]: readonly [FileSystem.FileSystem, Path.Path, string] )
scripts/validate-changesets.ts:104
↓ 2 callersFunctionremoveChannelFromActive
( activeChannels: Ref.Ref<HashSet.HashSet<string>>, channelName: string )
packages/eventsourcing-store-postgres/src/notificationListener.ts:232
↓ 2 callersFunctionrunClientServerContractTests
( name: string, setup: () => Effect.Effect<ClientServerTestContext> )
packages/eventsourcing-testing-contracts/src/lib/transport/client-server-contract-tests.ts:176
↓ 2 callersFunctionrunTestWithServerProtocol
( { server, clientTransport, }: { readonly server: ReadonlyDeep<InMemoryServer>; readonly
packages/eventsourcing-protocol/src/lib/protocol.test.ts:463
↓ 2 callersFunctionrunWithWriter
(effect: Effect.Effect<A, E2, FooEventStore>)
packages/eventsourcing-store/src/lib/testing/eventstore-test-suite.ts:563
↓ 2 callersFunctionsendAndVerifyCommandAfterNoise
( server: ReadonlyDeep<InMemoryServer>, clientTransport: ReadonlyDeep<Server.ClientConnection['transport']
packages/eventsourcing-protocol/src/lib/protocol.test.ts:611
↓ 2 callersFunctionsendCommandWithVerification
( command: ReadonlyDeep<WireCommand>, clientTransport: ReadonlyDeep<Server.ClientConnection['transport']>,
packages/eventsourcing-protocol/src/lib/protocol.test.ts:371
↓ 2 callersFunctionskip
(name, self, timeout)
packages/bun-test-effect/src/internal/internal.ts:131
↓ 2 callersFunctionstrictEqual
(actual: A, expected: A, message?: string, ..._: Array<never>)
packages/bun-test-effect/src/utils.ts:54
↓ 2 callersFunctionsubscribeAndBroadcast
( server: ServerTransport, client1: ClientTransport, client2: ClientTransport
packages/eventsourcing-testing-contracts/src/lib/transport/client-server-contract-tests.ts:338
↓ 2 callersFunctionsubscribeAndCollectMessages
( transport: ConnectedTransportTestInterface, filter: (msg: TransportMessage) => boolean, count: number
packages/eventsourcing-testing-contracts/src/lib/transport/client-transport-contract-tests.ts:199
↓ 2 callersFunctionsubscribeAndTakeEvents
(count: number, receivedEventsRef: Ref.Ref<Chunk.Chunk<FooEvent>>)
packages/eventsourcing-store/src/lib/testing/eventstore-test-suite.ts:37
↓ 2 callersFunctionsubscriber
(state: ConnectionState)
packages/eventsourcing-testing-contracts/src/lib/test-utilities.ts:123
↓ 2 callersFunctiontagEventsWithStreamId
( newEvents: Chunk.Chunk<V>, streamId: EventStreamId, startingEventNumber: number )
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:74
↓ 2 callersFunctiontoStringOutput
(value: unknown)
scripts/validate-changesets.ts:474
↓ 2 callersFunctionupdateSubscribersCount
(streamId: EventStreamId, delta: number)
packages/eventsourcing-store-inmemory/src/lib/subscriptionManager.ts:107
↓ 2 callersFunctionvalidateChangesetsFlow
(changesets: readonly ChangesetInfoInternal[])
scripts/validate-changesets.ts:815
↓ 2 callersFunctionvalidateCommand
(payloadSchema: Schema.Schema<TPayload, TPayloadInput>)
packages/eventsourcing-commands/src/lib/commands.ts:222
↓ 2 callersFunctionverifySingleTodoCreated
(expectedTitle: string)
packages/eventsourcing-server/src/lib/eventBus.test.ts:73
↓ 2 callersFunctionwrapPublish
(transport: { readonly publish: (msg: TransportMessage) => Effect.Effect<void, unknown> })
packages/eventsourcing-transport-inmemory/src/tests/integration/client-server.test.ts:41
↓ 2 callersFunctionwrapSubscribe
(transport: { readonly subscribe: ( filter?: (msg: TransportMessage) => boolean ) => Effect.Effe
packages/eventsourcing-transport-inmemory/src/tests/integration/client-server.test.ts:50
↓ 1 callersFunctionEventStreamTrackerLive
()
packages/eventsourcing-store-postgres/src/eventStreamTracker.ts:52
↓ 1 callersFunctionacquireWebSocketConnection
( url: Readonly<string>, stateRef: Readonly<Ref.Ref<WebSocketInternalState>>, writerRef: Readonly<Ref.Re
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:435
↓ 1 callersFunctionactivateAllEventsChannel
( activeChannels: Ref.Ref<HashSet.HashSet<string>>, client: PgClient.PgClient, notificationQueue: Queue.
packages/eventsourcing-store-postgres/src/notificationListener.ts:358
↓ 1 callersFunctionactivateAndListen
( activeChannels: Ref.Ref<HashSet.HashSet<string>>, client: PgClient.PgClient, notificationQueue: Queue.
packages/eventsourcing-store-postgres/src/notificationListener.ts:202
↓ 1 callersFunctionactivateChannelAndStartListening
( activeChannels: Ref.Ref<HashSet.HashSet<string>>, client: PgClient.PgClient, notificationQueue: Queue.
packages/eventsourcing-store-postgres/src/notificationListener.ts:187
↓ 1 callersFunctionaddCleanupFinalizer
(transport: Client.Transport, cleanup: () => Effect.Effect<void>)
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:424
↓ 1 callersFunctionaddClientToServerState
( serverStateRef: ReadonlyDeep<Ref.Ref<ServerState>>, clientState: ClientState )
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:277
↓ 1 callersFunctionaddConnectionStateSubscriber
(subscriber: (state: ConnectionState) => void)
packages/eventsourcing-testing-contracts/src/lib/test-utilities.ts:114
↓ 1 callersFunctionaddEqualityTesters
()
packages/bun-test-effect/src/internal/internal.ts:78
↓ 1 callersFunctionaddPubsubToSubs
(subs: HashMap.HashMap<EventStreamId, SubscriptionData<T>>, streamId: EventStreamId)
packages/eventsourcing-store-inmemory/src/lib/subscriptionManager.ts:57
↓ 1 callersFunctionaddQueueToClientSubscribers
(clientState: ReadonlyDeep<ClientState>)
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:128
↓ 1 callersFunctionaddSubscribeMethod
(store: InMemoryStore<T>)
packages/eventsourcing-store-inmemory/src/lib/inMemoryEventStore.ts:57
↓ 1 callersFunctionaddSubscriber
( clientState: ReadonlyDeep<InMemoryClientState>, subscriberQueue: ReadonlyDeep<Queue.Queue<TransportMessa
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:175
↓ 1 callersFunctionaddSubscriberToState
(stateRef: Readonly<Ref.Ref<WebSocketInternalState>>)
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:146
↓ 1 callersFunctionaddSubscriptionDataToMap
(streamId: EventStreamId, pubsub: PubSub.PubSub<T>)
packages/eventsourcing-store-inmemory/src/lib/subscriptionManager.ts:52
↓ 1 callersFunctionaddSubscriptionIfMissing
(streamId: EventStreamId)
packages/eventsourcing-store-inmemory/src/lib/subscriptionManager.ts:67
↓ 1 callersFunctionaddTransportFinalizer
( stateRef: Ref.Ref<MockTransportState>, transport: ConnectedTransportTestInterface )
packages/eventsourcing-testing-contracts/src/lib/test-utilities.ts:104
↓ 1 callersFunctionanalyzeArrowFunction
(node)
packages/eslint-effect/src/rules/suggest-currying-opportunity.js:112
↓ 1 callersFunctionanotherExtractedPipe
(msg: string)
packages/eslint-effect/test/no-nested-pipes.test.ts:39
↓ 1 callersFunctionappendEventToStream
(eventRows: EventRowServiceInterface)
packages/eventsourcing-store-postgres/src/sqlEventStore.ts:295
↓ 1 callersFunctionappendEventsAfterDelay
( store: EventStore<string>, streamId: EventStreamId, events: readonly string[] )
packages/eventsourcing-store-postgres/src/bridge.integration.test.ts:69
↓ 1 callersFunctionappendEventsAndUpdatePosition
(streamEnd: EventStreamPosition, newEvents: Chunk.Chunk<V>)
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:253
↓ 1 callersFunctionappendEventsAtPosition
( events: Chunk.Chunk<TEvent>, position: EventStreamPosition, eventstore: EventStore<TEvent> )
packages/eventsourcing-aggregates/src/lib/aggregateRootEventStream.ts:95
↓ 1 callersFunctionappendEventsAtPosition
(events: readonly FooEvent[], store: EventStore<FooEvent>)
packages/eventsourcing-store/src/lib/testing/eventstore-test-suite.ts:99
↓ 1 callersFunctionappendEventsToStream
(eventStore: EventStore<TEvent>)
packages/eventsourcing-aggregates/src/lib/commandProcessingFactory.ts:8
↓ 1 callersFunctionappendEventsToStream
( config: FileSystemStoreConfig, state: SynchronizedRef.SynchronizedRef<FileSystemStoreState<V>> )
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:299
↓ 1 callersFunctionappendForStore
(value: SynchronizedRef.SynchronizedRef<Value<V>>)
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:305
↓ 1 callersFunctionappendToBothStreamsAfterDelay
( store: EventStore<string>, stream1: { readonly id: EventStreamId; readonly events: readonly string[] },
packages/eventsourcing-store-postgres/src/bridge.integration.test.ts:120
↓ 1 callersFunctionappendToEventStream
(streamEnd: EventStreamPosition, newEvents: Chunk.Chunk<V>)
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:134
↓ 1 callersFunctionapplyConfigToMockWebSocket
(config: TestSocketConfig)
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.test.ts:151
↓ 1 callersFunctionapplyEntryToFiles
(currentDir: string)
scripts/validate-markdown-examples.ts:181
↓ 1 callersFunctionapplyEvent
(todoId: TodoId)
examples/todo-app/src/projections/todoProjection.ts:59
↓ 1 callersFunctionapplyEventAndAnnotate
( apply: ( data: ReadonlyDeep<Option.Option<TData>> ) => ( event: ReadonlyDeep<TEvent> ) => Effe
packages/eventsourcing-projections/src/lib/projection.ts:15
↓ 1 callersFunctionapplyEventAndUpdateRef
( apply: ( state: Readonly<Option.Option<TState>> ) => (event: Readonly<TEvent>) => Effect.Effect<TSta
packages/eventsourcing-aggregates/src/lib/aggregateRootEventStream.ts:157
← previousnext →101–200 of 1,511, ranked by callers