jredville

# Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.

module RX
  module Notification

    class << self

      def create_on_next(value)
        OnNextNotification.new value
      end

jredville

# Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.

module RX

  # Records information about subscriptions to and unsubscriptions from observable sequences.
  class TestSubscription < Struct.new(:subscribe, :unsubscribe)

    FIXNUM_MAX = (2**(0.size * 8 -2) -1)

    def initialize(subscribe, unsubscribe = FIXNUM_MAX)

jredville

<h1>Try to Pull the Arrow <span class="me">Down</span></h1>

<div class="wrapper wbot">
  <div class="content">    
    <ul>
      <li><a href="#">Cool, HUH</a></li>
      <li><a href="#">Try to</a></li>
      <li><a href="#">Pull the</a></li>
      <li><a href="#">Arrow Up</a></li>
      <li><a href="http://codepen.io/mmoustafa" target="_blank" class="me">mmoustafa</a></li>