createStream: (
asked?: any,
context?: any,
) =>
| { errors: any[]; limit: boolean; ok: boolean; stream: any }
| { errors: any[]; limit?: undefined; ok: boolean; stream: any }
| {
errors: any[];
limit?: undefined;
ok: boolean;
stream: {
aud: any;
counters: {
acknowledged: number;
delivered: number;
failed: number;
pollCalls: number;
pushCalls: number;
queued: number;
receiverErrors: number;
};
createdAt: string;
createdBy: string;
delivery: {
authorization_header: string;
endpoint_url: string;
method: any;
};
description: string;
eventCounts: {};
events_delivered: any;
events_requested: string[];
events_supported: any;
format: string;
internalSurface: string;
iss: string;
lastActivityAt: number;
lastPushAt: string;
lastPushError: string;
lastVerificationAt: number;
log: any[];
min_verification_interval: any;
ownerPerson: OwnerPerson;
status: string;
statusReason: string;
stream_id: string;
subjects: any[];
updatedAt: string;
};
} = ...
Type Declaration
-
- (
asked?: any,
context?: any,
):
| { errors: any[]; limit: boolean; ok: boolean; stream: any }
| { errors: any[]; limit?: undefined; ok: boolean; stream: any }
| {
errors: any[];
limit?: undefined;
ok: boolean;
stream: {
aud: any;
counters: {
acknowledged: number;
delivered: number;
failed: number;
pollCalls: number;
pushCalls: number;
queued: number;
receiverErrors: number;
};
createdAt: string;
createdBy: string;
delivery: {
authorization_header: string;
endpoint_url: string;
method: any;
};
description: string;
eventCounts: {};
events_delivered: any;
events_requested: string[];
events_supported: any;
format: string;
internalSurface: string;
iss: string;
lastActivityAt: number;
lastPushAt: string;
lastPushError: string;
lastVerificationAt: number;
log: any[];
min_verification_interval: any;
ownerPerson: OwnerPerson;
status: string;
statusReason: string;
stream_id: string;
subjects: any[];
updatedAt: string;
};
}
-
Parameters
Optionalasked: any
Optionalcontext: any
Returns
| { errors: any[]; limit: boolean; ok: boolean; stream: any }
| { errors: any[]; limit?: undefined; ok: boolean; stream: any }
| {
errors: any[];
limit?: undefined;
ok: boolean;
stream: {
aud: any;
counters: {
acknowledged: number;
delivered: number;
failed: number;
pollCalls: number;
pushCalls: number;
queued: number;
receiverErrors: number;
};
createdAt: string;
createdBy: string;
delivery: {
authorization_header: string;
endpoint_url: string;
method: any;
};
description: string;
eventCounts: {};
events_delivered: any;
events_requested: string[];
events_supported: any;
format: string;
internalSurface: string;
iss: string;
lastActivityAt: number;
lastPushAt: string;
lastPushError: string;
lastVerificationAt: number;
log: any[];
min_verification_interval: any;
ownerPerson: OwnerPerson;
status: string;
statusReason: string;
stream_id: string;
subjects: any[];
updatedAt: string;
};
}
{ ok, stream, errors }
Creates a stream from a receiver's Stream Configuration.
This service fills every transmitter-owned member: it mints
stream_id, setsiss, assignsaudfrom the receiver's associated identifiers, and agreesevents_deliveredas the intersection of what was requested, what is supported and what the owner's entry allows.