ldayan

// This is your Prisma schema file,
// learn more about it in the docs

generator client {
  provider = "prisma-client-js"
}

datasource db {
  provider = "postgresql"
  url      = env("PG_URL")

ldayan

1. General Background and Overview

• Probabilistic Data Structures for Web Analytics and Data Mining : A great overview of the space of probabilistic data structures and how they are used in approximation algorithm implementation.
• Models and Issues in Data Stream Systems
• Philippe Flajolet’s contribution to streaming algorithms : A presentation by Jérémie Lumbroso that visits some of the hostorical perspectives and how it all began with Flajolet
• Approximate Frequency Counts over Data Streams by Gurmeet Singh Manku & Rajeev Motwani : One of the early papers on the subject.
• [Methods for Finding Frequent Items in Data Streams](http://citeseerx.ist.psu.edu/viewdoc/download?doi=10.1.1.187.9800&rep

ldayan

-- clean up database from previous test
DROP SCHEMA public CASCADE;
CREATE SCHEMA public;

-- create EAV tables
CREATE TABLE entity ( 
  id           SERIAL PRIMARY KEY, 
  name         TEXT, 
  description  TEXT
);

ldayan

  sealed trait EdnExpr {
    def value : Expr
    def mdata : Map[Expr,Expr]
    override def equals(other : Any) = other match {
      case that : EdnExpr => this.value == that.value
      case _ => false
    }
  }
  type Expr = Any
  

ldayan

A state machine is defined as follows:

• Input - a set of inputs
• Output - a set of outputs
• State - a set of states
• S0 ∈ S - an initial state
• T : Input * State -> Output * State - a transition function

If you model your services (aggregates, projections, process managers, sagas, whatever) as state machines, one issue to address is management of State. There must be a mechanism to provide State to the state machine, and to persist resulting State for subsequent retrieval. One way to address this is by storing State is a key-value store. Another way is to use a SQL database. Yet another way is event sourcing. The benefit of even sourcing is that you never need to store State itself. Instead, you rely on the Output of a service to reconstitute state. In order to do that, the state machine transition function needs to be factored into two functions as follows:

ldayan

import { Dispatcher } from 'flux'

function isPromise(obj) {
  return obj && (typeof obj === 'object' || typeof obj === 'function') &&
    typeof obj.then === 'function'
}

const inject = Math.random().toString(16).substr(2, 7)

class Alt {

ldayan

curl -sS https://getcomposer.org/installer | php
composer global require drush/drush:dev-master
drush qd --core=drupal-8.0.x
# Note the password created for admin will be different from the examples. Either change example or in your Drupal install.
cd quick-drupal
drush en rest hal basic_auth -y
# Create a new page node
curl --include \
  --request POST \
  --user admin:password \

ldayan

The introduction to Reactive Programming you've been missing

(by @andrestaltz)

So you're curious in learning this new thing called Reactive Programming, particularly its variant comprising of Rx, Bacon.js, RAC, and others.

Learning it is hard, even harder by the lack of good material. When I started, I tried looking for tutorials. I found only a handful of practical guides, but they just scratched the surface and never tackled the challenge of building the whole architecture around it. Library documentations often don't help when you're trying to understand some function. I mean, honestly, look at this:

Rx.Observable.prototype.flatMapLatest(selector, [thisArg])

Projects each element of an observable sequence into a new sequence of observable sequences by incorporating the element's index and then transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.

ldayan

server {
	listen   80; ## listen for ipv4; this line is default and implied
	#listen   [::]:80 default ipv6only=on; ## listen for ipv6

	root /home/example/public;
	index index.php index.html index.htm;

	# Make site accessible from http://localhost/
	server_name dev.apigility.com;

ldayan

<?php
/* We'll assume that all of the above classes are defined.
 *
 * We'll assume that Api\V1\Rpc\Query\QueryController will handle an RPC service
 * call to /search?s=thing. It needs to be configured such that it responds to 
 * GET requests, and Content Negotiation is set to HalJson.
 *
 * This is what it will look like:
 */