dmorosinotto

//Helper function to handle async call (Observable generator with strategy + safe retry if error) to push value to Signal - useful for State Management with Signal
//READ MORE https://medium.com/@eugeniyoz/application-state-management-with-angular-signals-b9c8b3a3afd7
//ORIGINAL DOCS (NgRx component-store effect) https://ngrx.io/guide/component-store/effect#effect-method
import { isObservable, Observable, of, retry, Subject, Subscription } from 'rxjs';
import { takeUntilDestroyed } from '@angular/core/rxjs-interop';
import { DestroyRef, inject } from '@angular/core';

/**
 * This code is a copied `ComponentStore.effect()` method from NgRx and edited to:
 * 1) be a standalone function;

dmorosinotto

const log = (tag: string) => tap(
  next => console.log(`%c[${tag}: Next]`, 'color: #4CAF50;', next),
  error => console.log(`%c${tag}: Error]`, 'color: #F44336;', error),
  () => console.log(`%c[${tag}: Complete]`, 'color: #2196F3;')
);

dmorosinotto

#RxJS 5 Operators By Example

UPDATE: I have moved the contents of this gist plus more to https://github.com/btroncone/learn-rxjs and http://www.learnrxjs.io. For expanded examples, explanations, and resources, please check out this new location!

A complete list of RxJS 5 operators with easy to understand explanations and runnable examples.

Chinese Version by: @DrakeLeung

Table of Contents

• buffer

dmorosinotto

Comprehensive Introduction to @ngrx/store

By: @BTroncone

Also check out my lesson @ngrx/store in 10 minutes on egghead.io!

Update: Non-middleware examples have been updated to ngrx/store v2. More coming soon!

Table of Contents

dmorosinotto

/*!
 An experiment in getting accurate visible viewport dimensions across devices
 (c) 2012 Scott Jehl. 
 MIT/GPLv2 Licence
*/

function viewportSize(){
	var test = document.createElement( "div" );

	test.style.cssText = "position: fixed;top: 0;left: 0;bottom: 0;right: 0;";

dmorosinotto

node-websocketd

A lightweight node port of websocketd, originally written in go.

Usage

node-websocketd --port=8080 ./count.sh

dmorosinotto

        public Func<IDictionary<string, object>, Task<object>> Invoke(Func<IDictionary<string, object>, object> executor)
        {
            Func<IDictionary<string, object>, Task<object>> invoker = null;

            if (executor.Method.ReturnType != typeof (Task<object>))
            {
                invoker =
                    p =>
                    {
                        var task = new Task<object>(() => executor(p));

dmorosinotto

function backup() {
    var request = require('request');
    var util = require('util');
    
    var date = new Date();
    var year = date.getUTCFullYear();
    var month = date.getUTCMonth() + 1;
    var day = date.getUTCDate();
    
    var body = {

dmorosinotto

function read(query, user, request) {

    var dispatch = {
        op1 : operation1,
        op2 : operation2,
    }

    if (request.parameters.operation && dispatch.hasOwnProperty(request.parameters.operation)) {
        dispatch[request.parameters.operation](query, user, request);
        return;

dmorosinotto

function read(query, user, request) {
    var queryComponents = query.getComponents();
    /*
    { filters: null,
      selections: [],
      projection: null,
      ordering: {},
      skip: null,
      take: 50,
      table: 'test',