qmzik

import axios, { CancelTokenStatic } from 'axios';

export const http = axios.create({
    baseURL: 'https://api.domen.com/',
});

const cancelToken: CancelTokenStatic = axios.CancelToken;
export let cancelSource = cancelToken.source();
export const refreshTokenForUpdateApp = (() => {
    cancelSource = cancelToken.source();

qmzik

import { Observable } from 'rxjs';
 
const source = new Observable<number>((subscriber) => {
  subscriber.next(1);
  subscriber.next(2);
  subscriber.next(3);
  subscriber.complete();
});
 
// Usage

qmzik

/**
 * A simple object with a `next` and `complete` callback on it.
 */
interface Observer<T> {
  next: (value: T) => void;
  complete: () => void;
}
 
/**
 * A function that takes a simple object with callbacks

qmzik

const source = function (subscriber: Observer<number>) {
  subscriber.next(1);
  subscriber.next(2);
  subscriber.next(3);
  subscriber.complete();
  subscriber.next(4); // Упс, этого не должно быть
};

qmzik

/**
 * A class used to wrap a user-provided Observer. Since the
 * observer is just a plain objects with a couple of callbacks on it,
 * this type will wrap that to ensure `next` does nothing if called after
 * `complete` has been called, and that nothing happens if `complete`
 * is called more than once.
 */
class SafeSubscriber<T> {
  closed = false;
 

qmzik

class SafeSubscriber<T> {
  closed = false;
 
  constructor(private destination: Partial<Observer<T>>) {}
 
  next(value: T) {
    if (!this.closed) {
      this.destination.next?.(value); // Note the ?. check here.
    }
  }

qmzik

interface Observer<T> {
  next: (value: T) => void;
  complete: () => void;
  error: (err: any) => void;
}

qmzik

class SafeSubscriber<T> {
  closed = false;
 
  constructor(private destination: Partial<Observer<T>>) {}
 
  next(value: T) {
    if (!this.closed) {
      this.destination.next?.(value);
    }
  }

qmzik

const helloSocket = new Observable<string>((subscriber) => {
  // Open a socket.
  const socket = new WebSocket('wss://echo.websocket.org');
 
  socket.onopen = () => {
    // Once it's open, send some text.
    socket.send('Hello, World!');
  };
 
  socket.onmessage = (e) => {

qmzik

const source = (subscriber: Observer<string>) => {
  const socket = new WebSocket('wss://echo.websocket.org');
 
  socket.onopen = () => {
    socket.send('Hello, World!');
  };
 
  socket.onmessage = (e) => {
    subscriber.next(e.data);
  };