rarmatei

class AmountInput {
  private static MAX_ALLOWED = 99_999_999;

  amount: number = 0;

  showTooltip() {
    //show tooltip
    setTimeout(() => {
      //hide tooltip
    }, 2_500);

rarmatei

import React from "react";

function Results() {
  return (
    <table>
      <tr>
        <th> Title </th>
        <th> First name </th>
        <th> Surname </th>
        <th> Email </th>

rarmatei

class Book {
  title: string;
}

class Television {
  screenSize: string;
}

function relaxWith(item: Book | Television) {
  if(item instanceof Book) {

rarmatei

class MyService3 {

  constructor() {
    this._producer = Rx.Observable.of(1)
      .publish();
  }

  private _producer: Rx.ConnectableObservable<number>;

  startItUp(): Rx.Observable<number> {

rarmatei

class MyService {

  constructor() {
    this._producer = Rx.Observable.of(1)
      .publish();
  }

  private _producer: Rx.ConnectableObservable<number>;

  startItUp(): Rx.Observable<number> {

rarmatei

class MyService {

  constructor() {
    this._producer = Rx.Observable.interval(1000)
      .publish();
  }

  private _producer: Rx.ConnectableObservable<number>;

  startItUp(): Rx.Observable<number> {

rarmatei

function delayedRefCount(delay) {
  return (source) => {
    const subscribeUpdates = new Subject();
    let trackerConnection;
    let subscriptionTracker = subscribeUpdates.scan((total, change) => change + total, 0)
      .switchMap(count => {
        return count === 0
          ? Observable.timer(delay)
            .do(_ => source.connect().unsubscribe() || trackerConnection.unsubscribe())
          : Observable.never();

rarmatei

subscribeUpdates
  .scan((total, change) => change + total, 0)
  .switchMap(count => {
    return count === 0
      ? Observable.timer(delay)
        .do(_ => /* tear-down logic */ )
      : Observable.never();
  });

rarmatei

function delayedRefCount(delay) {
  return (source) => {
    let length = 0;
    let timeout;
    const onNewSubscriber = () => {
      const onUnsubscribe = () => {
        length--;
        if (length === 0) {
          timeout = setTimeout(() => {
            source.connect().unsubscribe();

rarmatei

function refCount(source) {
  let length = 0;
  const onNewSubscriber = () => {
    const onUnsubscribe = () => {
      length--;
      if(length === 0) {
        source.connect().unsubscribe();
      }
    };
    length++;