Skip to content

Main Navigation Guide Reference

Appearance

Sidebar Navigation

Introduction

What is eventkit?

Getting Started

Motivations

Concepts

Creating Streams

Transforming Data

Observable Pattern

Async Processing

Scheduling

Examples

Reactive Systems

HTTP Streaming

Reference

@eventkit/base

Classes

AsyncObservable

CallbackSubscriber

SingletonAsyncObservable

Stream

Subscriber

Interfaces

SchedulerLike

SubscriptionLike

Type Aliases

AsyncObservableInput

MonoTypeOperatorFunction

ObservedValueOf

OperatorFunction

ReadableStreamLike

RetryBackoff

RetryStrategy

StreamInit

SubscriberCallback

UnaryFunction

Errors

ArgumentOutOfRangeError

InvalidConcurrencyLimitError

NoValuesError

Operators

buffer

bufferCount

concat

concatAll

concatMap

count

dlq

elementAt

every

filter

find

findIndex

first

isEmpty

last

map

max

merge

mergeAll

mergeMap

min

pairwise

partition

reduce

retry

skip

takeUntil

withOwnScheduler

withScheduler

Scheduling

CallbackAction

CleanupAction

DeferredPassthroughScheduler

PassthroughScheduler

QueueScheduler

ScheduledAction

Scheduler

SubjectQueueScheduler

QueueSchedulerInit

Utilities

from

isAsyncObservable

pipe

@eventkit/http

Classes

EventSource

EventSourceResponse

WebSocket

Type Aliases

EventSourceEvent

EventSourceMessage

EventSourceResponseInit

EventSourceSerializerInit

Functions

eventSourceObservable

websocketObservable

On this page

Documentation / @eventkit/base / SubscriptionLike

Interface: SubscriptionLike

Methods

cancel()

ts

cancel(): Promise<void>

Returns

Promise<void>

Suggest changes to this page

Pager

Previous pageSchedulerLike

Next pageAsyncObservableInput

Released under the MIT License.

Copyright © 2025-present Hunter Lovell & eventkit contributors