meteor-subscribe.html

<!--
Subscribe to a Meteor (DDP) server publication.

Example :

      <meteor-subscribe name="peoples" args="[]" isready="{{subready}}"></meteor-subscribe>

-->

<script>
  Polymer({
    is: 'meteor-subscribe',

    /**
     * Fired when the subscribtion becomes ready (first shot of results received).
     *
     * @event subscribe-ready
     */

    /**
     * Fired when an error occurs. The detail object contains the error.
     *
     * @event subscribe-error
     */

    properties: {
      /**
       * Publish name to subscribe.
       */
      name: {
        type: String,
        value: ""
      },

      /**
       * The subscribe arguments.
       */
      args: {
        type: Array,
        value: null
      },

      /**
       * Wait to get an Array on args to start subscription
       */
      waitargs: {
        type: Boolean,
        value: true
      },

      /**
       * Ready state (first shot of results received).
       */
      isready: {
        type: Boolean,
        value: false,
        notify: true
      }
    },
    observers: [ '_resub(name, args, waitargs)' ],
    _resub: function(name, args, waitargs) {
      //console.log("(re)subscribe meteor-subscribe "+name+" "+ args);
      this.stop();

      if (this.name && (args instanceof Array || !waitargs)) {
        var callargs = this.args.slice(0);
        callargs.unshift(this.name);
        callargs.push({
          onStop: function(err) {
            if (err)
              this.fire('subscribe-error', { error: err });
            this.isready = false;
          }.bind(this),
          onReady: function() {
            this.isready = true;
            this.fire('subscribe-ready');
          }.bind(this)
        });

        this._handle = Meteor.subscribe.apply(null, callargs);
      }
    },
    /** Stop this subscription */
    stop: function() {
      if (this._handle) {
        this._handle.stop();
        this._handle = null;
      }
    },
    ready: function() {
    }
  });
</script>