common.api.stream_get_actor

All Samples(17) | Call(17) | Derive(0) | Import(0)

src/c/o/CollabQ-HEAD/actor/views.py CollabQ(Download)

                                       offset=offset)
 
  actor_streams = api.stream_get_actor(request.user, view.nick)
  entries, more = helper.get_inbox_entries(request, inbox, False, per_page, True, view)
  contacts, channels, streams, entries = helper.assemble_inbox_data(request, entries, actor_streams, view)

 
  stream_keys = [e.stream for e in entries]
  actor_streams = api.stream_get_actor(request.user, view.nick)
  stream_keys += [s.key().name() for s in actor_streams]
  streams = api.stream_get_streams(request.user, stream_keys)

src/c/o/CollabQ-HEAD/channel/views.py CollabQ(Download)

 
  stream_keys = [e.stream for e in entries]
  actor_streams = api.stream_get_actor(request.user, view.nick)
  stream_keys += [s.key().name() for s in actor_streams]
  streams = api.stream_get_streams(request.user, stream_keys)

src/j/a/JaikuEngine-HEAD/channel/views.py JaikuEngine(Download)

 
  stream_keys = [e.stream for e in entries]
  actor_streams = api.stream_get_actor(request.user, view.nick)
  stream_keys += [s.key().name() for s in actor_streams]
  streams = api.stream_get_streams(request.user, stream_keys)

src/j/a/jaikuenginepatch-HEAD/channel/views.py jaikuenginepatch(Download)

 
  stream_keys = [e.stream for e in entries]
  actor_streams = api.stream_get_actor(request.user, view.nick)
  stream_keys += [s.key().name() for s in actor_streams]
  streams = api.stream_get_streams(request.user, stream_keys)

src/j/a/JaikuEngine-HEAD/actor/views.py JaikuEngine(Download)

                                       offset=offset)
 
  actor_streams = api.stream_get_actor(request.user, view.nick)
  entries, more = _get_inbox_entries(request, inbox,
                                     view.extra.get('comments_hide', 0))

src/j/a/jaikuenginepatch-HEAD/actor/views.py jaikuenginepatch(Download)

                                       offset=offset)
 
  actor_streams = api.stream_get_actor(request.user, view.nick)
  entries, more = _get_inbox_entries(request, inbox,
                                     view.extra.get('comments_hide', 0))

src/c/o/CollabQ-HEAD/hashtag/views.py CollabQ(Download)

    stream_keys = [e.stream for e in entries]
    try:
      actor_streams = api.stream_get_actor(request.user, view.nick)
    except exception.ApiException:
      actor_streams = []

src/j/a/JaikuEngine-HEAD/common/test/api.py JaikuEngine(Download)

    public_target = api.actor_get(api.ROOT, self.unpopular_nick)
 
    public_streams = api.stream_get_actor(api.ROOT, self.unpopular_nick)
    self.assert_(len(public_streams))

    # pending subscriptions for all their streams
    private_target = api.actor_get(api.ROOT, self.hermit_nick)
    private_streams = api.stream_get_actor(api.ROOT, private_target.nick)
    self.assert_(len(private_streams))

    # that were marked as pending are allowed
    # XXX this test relies on the results of the previous test being correct
    subscriber_streams = api.stream_get_actor(api.ROOT, subscriber.nick)
    self.assert_(len(subscriber_streams))

src/c/o/CollabQ-HEAD/common/test/api.py CollabQ(Download)

    public_target = api.actor_get(api.ROOT, self.unpopular_nick)
 
    public_streams = api.stream_get_actor(api.ROOT, self.unpopular_nick)
    self.assert_(len(public_streams))

    # pending subscriptions for all their streams
    private_target = api.actor_get(api.ROOT, self.hermit_nick)
    private_streams = api.stream_get_actor(api.ROOT, private_target.nick)
    self.assert_(len(private_streams))

    # that were marked as pending are allowed
    # XXX this test relies on the results of the previous test being correct
    subscriber_streams = api.stream_get_actor(api.ROOT, subscriber.nick)
    self.assert_(len(subscriber_streams))

src/j/a/jaikuenginepatch-HEAD/common/test/api.py jaikuenginepatch(Download)

    public_target = api.actor_get(api.ROOT, self.unpopular_nick)
 
    public_streams = api.stream_get_actor(api.ROOT, self.unpopular_nick)
    self.assert_(len(public_streams))

    # pending subscriptions for all their streams
    private_target = api.actor_get(api.ROOT, self.hermit_nick)
    private_streams = api.stream_get_actor(api.ROOT, private_target.nick)
    self.assert_(len(private_streams))

    # that were marked as pending are allowed
    # XXX this test relies on the results of the previous test being correct
    subscriber_streams = api.stream_get_actor(api.ROOT, subscriber.nick)
    self.assert_(len(subscriber_streams))