teyfix

const subject = new Subject();

subject.subscribe(
  (value) => console.log(value),
  (error) => console.error(error),
  () => console.log('özne sonlandı'),
);
subject.complete();

teyfix

const subject = new Subject();

subject.subscribe(value => console.log(value));
subject.next('lorem');
subject.next('ipsum');
subject.next('dolor');

teyfix

const subject = new Subject();

subject.next(1);
subject.next(2);
subject.next(3);

teyfix

import { fromEvent, Subject } from 'rxjs';
import { map, shareReplay, switchMap } from 'rxjs/operators';
import io from 'socket.io-client';

const $token = new Subject();
const $client = $token.pipe(
  map((token) => {
    if (null == token || '' === token) {
      return {};
    }

teyfix

subject.pipe(
  map(x => x * x),
);

teyfix

import { fromEvent } from 'rxjs';
import io from 'socket.io-client';

const client = io().connect();
const listen = (event: string) => fromEvent(client, event);

listen('message').subscribe((message) => console.log(message));

teyfix

const subject = new Subject();
const subscription = subject.subscribe(value => console.log(value));

subject.next('foo');
subject.next('bar');
subscription.unsubscribe();

teyfix

const fibonacci = new BehaviorSubject(1);

fibonacci.next(1);
fibonacci.next(2);
fibonacci.next(3);
fibonacci.next(5);
fibonacci.next(8);

console.log(fibonacci.value);

teyfix

const user = new ReplaySubject(1);

authorize(session => user.next(session.user));

teyfix

const store = Vuex.Store({
  state: {
    user: null,
  },
});