canStream.toStream( observable, propAndOrEvent )

Creates a stream from a can-compute compute or an observable. This stream gets updated whenever the observable value changes.

import compute from "can-compute";
import canStreamKefir from "can-stream-kefir";
import canStream from "can-stream";
const canStreaming = canStream( canStreamKefir );

const c1 = compute( 0 );

const resultCompute = canStreaming.toStream( c1 );

resultCompute.onValue( function( val ) {
  console.log( val );
} );

c1( 1 );

canStream.toStream( observable, "eventName" )

Creates an event stream with the event objects dispatched on obs for eventName. This is a shorthand for [can-stream.toStreamFromEvent].

import DefineList from "can-define/list/list";
import canStreamKefir from "can-stream-kefir";
import canStream from "can-stream";
const canStreaming = canStream( canStreamKefir );

const hobbies = new DefineList( [ "js", "kayaking" ] );

const changeCount = canStreaming.toStream( hobbies, "length" ).scan( function( prev ) {
  return prev + 1;
}, 0 );
changeCount.onValue( function( event ) {
  console.log( event );
} );

hobbies.push( "bball" );

//-> console.logs {type: "add", args: [2,["bball"]]}
hobbies.shift();

//-> console.logs {type: "remove", args: [0,["js"]]}

canStream.toStream( observable, ".propName" )

Creates a stream from an observable property value. This is a shorthand for [can-stream.toStreamFromProperty].

import canStreamKefir from "can-stream-kefir";
import canStream from "can-stream";
const canStreaming = canStream( canStreamKefir );

import DefineMap from "can-define/map/map";

const person = new DefineMap( {
  first: "Justin",
  last: "Meyer"
} );

const first = canStreaming.toStream( person, ".first" );
const last = canStreaming.toStream( person, ".last" );

const fullName = Kefir.combine( first, last, function( first, last ) {
  return first + last;
} );

fullName.onValue( function( newVal ) {
  console.log( newVal );
} );

map.first = "Payal";

//-> console.logs "Payal Meyer"

Create a stream based on a event on an observable property.

canStream.toStream( obs, ".propName eventName" )

Creates a stream from an observable property value. This is a shorthand for the second signature of [can-stream.toStreamFromEvent].

import canStreamKefir from "can-stream-kefir";
import canStream from "can-stream";
const canStreaming = canStream( canStreamKefir );

import DefineMap from "can-define/map/map";
import DefineList from "can-define/list/list";

const me = new DefineMap( {
  todos: [ "mow lawn" ]
} );

const addStream = canStreaming.toStream( me, ".todos add" );

addStream.onValue( function( event ) {
  console.log( event );
} );

map.todos.push( "do dishes" );

//-> console.logs {type: "add", args: [1,["do dishes"]]}

Create a stream based on a event on an observable property.