33 lines · 1.1 KB · TypeScript
RawDownload
import * as Context from "effect/Context";import * as Layer from "effect/Layer";import type * as Stream from "effect/Stream"; export type ConnectionWakeup =  | "application-active"  | "application-active-probe"  | "application-active-reconnect"  | "credentials-changed"; export function isApplicationActiveWakeup(reason: ConnectionWakeup): boolean {  return (    reason === "application-active" ||    reason === "application-active-probe" ||    reason === "application-active-reconnect"  );} export function shouldResubscribeAfterWakeup(reason: ConnectionWakeup): boolean {  return reason === "application-active" || reason === "application-active-probe";} export class ConnectionWakeups extends Context.Service<  ConnectionWakeups,  {    readonly changes: Stream.Stream<ConnectionWakeup>;  }>()("@t3tools/client-runtime/connection/wakeups/ConnectionWakeups") {} export const make = (service: ConnectionWakeups["Service"]) => ConnectionWakeups.of(service); export const layer = (service: ConnectionWakeups["Service"]) =>  Layer.succeed(ConnectionWakeups, make(service));

Keyboard shortcuts

General

Show keyboard shortcuts
?
Focus the current search
/

Issues and pull requests

Open filters
f

Issues, pull requests and Inbox

Select next item
j↓
Select previous item
k↑
Open selected item
Enter
Dismiss filters or clear selection
Esc

Repository code

Go to file
t