dezfowler

<?xml version="1.0" encoding="utf-8"?>
<Client name="Chromecast">
  <!-- Author: Derek Fowler. -->
  <TranscodeTargets>
    <VideoProfile protocol="http" container="mkv" codec="h264" audioCodec="aac" context="streaming">
      <Setting name="VideoEncodeFlags" value="-x264opts bframes=3:cabac=1" />
    </VideoProfile>
    <MusicProfile container="wav" codec="pcm_s16le"/>
    <PhotoProfile container="jpeg" />
    <SubtitleProfile container="ass" codec="ass" />

dezfowler

using System;
using System.Collections.Generic;

public class MyClass
{
	public static void RunSnippet()
	{
		// http://blog.robustsoftware.co.uk/2010/04/currying-with-c.html
		// http://gist.github.com/360105
		

dezfowler

/// <summary>
/// Allows UI and code operations to be executed sequentially.
/// </summary>
public class Sequence
{
	private Sequence _start;
	private Sequence _next;
	private bool _alreadyRun = false;

	public Sequence()

dezfowler

{
  "links": {
    "self": "http://example.com/articles",
    "next": "http://example.com/articles?page[offset]=2",
    "last": "http://example.com/articles?page[offset]=10"
  },
  "data": [{
    "type": "articles",
    "id": "1",
    "attributes": {

dezfowler

using System;
using System.Collections.Generic;
using System.Collections.Concurrent;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;

namespace myApp
{
    class Program

dezfowler

const Clock = rxify((initialProps, prop$) => {
  return prop$
    .pipe(
      filter(pd => pd.differences.includes('running')),
      map(pd => pd.next.running),
      switchMap(running => running ? interval(0, 1000) : empty()),
      startWith(1),
      map(_ => (<span className="time">{new Date().toLocaleTimeString()}</span>))
    )
});

dezfowler

class Clock extends React.Component {
  constructor(props) {
    super(props);
    this.intervalId = undefined;
    this.state = { time: new Date() };      
  }
    
  componentWillUnmount() {
    this.stopTick();
  }

dezfowler

class Clock extends React.Component {
  constructor(props) {
    super(props);
    console.log('new');
    this.state = { time: new Date() };
  }

  componentDidMount() {
    this.propsChangeSubject = new Subject();
    this.subscription = this.propsChangeSubject

dezfowler

const { interval, empty } = require('rxjs');
const { switchMap, startWith, map } = require('rxjs/operators');

const Clock = rxify((initialProps, prop$) => {
  return prop$
    .pipe(
      switchMap(props => props.running ? interval(0, 1000) : empty()),
      startWith(1),
      map(_ => (<span className="time">{new Date().toLocaleTimeString()}</span>))
    )

dezfowler

import { ofType } from 'redux-observable';

const pingEpic = action$ => action$.pipe(
  ofType('PING'),
  delay(1000), // Asynchronously wait 1000ms then continue
  mapTo({ type: 'PONG' })
);