code: def execute(self, program, start=None, stop=None, resolution=None,
                  max_delay=None, persistent=False, immediate=False,
                  disable_all_metric_publishes=None):
          
          params = self._get_params(start=start, stop=stop,
                                    resolution=resolution,
                                    maxDelay=max_delay,
                                    persistent=persistent,
                                    immediate=immediate,
                                    disableAllMetricPublishes=disable_all_metric_publishes)
  
          def exec_fn(since=None):
              if since:
                  params['start'] = since
              return self._transport.execute(program, params)
  
          c = computation.Computation(exec_fn)
          self._computations.add(c)
          return c
docs: Execute the given SignalFlow program and stream the output back.