Package io.getstream.core

Class StreamBatch

java.lang.Object

io.getstream.core.StreamBatch

public final class StreamBatch
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
StreamBatch(java.lang.String key, java.net.URL baseURL, HTTPClient httpClient)

Method Summary

Modifier and Type	Method	Description
java8.util.concurrent.CompletableFuture<java.lang.Void>	addToMany(Token token, Activity activity, FeedID... feeds)
java8.util.concurrent.CompletableFuture<java.lang.Void>	followMany(Token token, int activityCopyLimit, FollowRelation... follows)
java8.util.concurrent.CompletableFuture<java.util.List<Activity>>	getActivitiesByForeignID(Token token, ForeignIDTimePair... activityIDTimePairs)
java8.util.concurrent.CompletableFuture<java.util.List<Activity>>	getActivitiesByID(Token token, java.lang.String... activityIDs)
java8.util.concurrent.CompletableFuture<java.util.List<EnrichedActivity>>	getEnrichedActivitiesByForeignID(Token token, ForeignIDTimePair... activityIDTimePairs)
java8.util.concurrent.CompletableFuture<java.util.List<EnrichedActivity>>	getEnrichedActivitiesByID(Token token, java.lang.String... activityIDs)
java8.util.concurrent.CompletableFuture<java.lang.Void>	unfollowMany(Token token, UnfollowOperation... unfollows)
java8.util.concurrent.CompletableFuture<java.lang.Void>	updateActivities(Token token, Activity... activities)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamBatch

public StreamBatch(java.lang.String key,
                   java.net.URL baseURL,
                   HTTPClient httpClient)

Method Detail

addToMany

public java8.util.concurrent.CompletableFuture<java.lang.Void> addToMany(Token token,
                                                                         Activity activity,
                                                                         FeedID... feeds)
                                                                  throws StreamException

Throws:

StreamException

followMany

public java8.util.concurrent.CompletableFuture<java.lang.Void> followMany(Token token,
                                                                          int activityCopyLimit,
                                                                          FollowRelation... follows)
                                                                   throws StreamException

Throws:

StreamException

unfollowMany

public java8.util.concurrent.CompletableFuture<java.lang.Void> unfollowMany(Token token,
                                                                            UnfollowOperation... unfollows)
                                                                     throws StreamException

Throws:

StreamException

getActivitiesByID

public java8.util.concurrent.CompletableFuture<java.util.List<Activity>> getActivitiesByID(Token token,
                                                                                           java.lang.String... activityIDs)
                                                                                    throws StreamException

Throws:

StreamException

getEnrichedActivitiesByID

public java8.util.concurrent.CompletableFuture<java.util.List<EnrichedActivity>> getEnrichedActivitiesByID(Token token,
                                                                                                           java.lang.String... activityIDs)
                                                                                                    throws StreamException

Throws:

StreamException

getActivitiesByForeignID

public java8.util.concurrent.CompletableFuture<java.util.List<Activity>> getActivitiesByForeignID(Token token,
                                                                                                  ForeignIDTimePair... activityIDTimePairs)
                                                                                           throws StreamException

Throws:

StreamException

getEnrichedActivitiesByForeignID

public java8.util.concurrent.CompletableFuture<java.util.List<EnrichedActivity>> getEnrichedActivitiesByForeignID(Token token,
                                                                                                                  ForeignIDTimePair... activityIDTimePairs)
                                                                                                           throws StreamException

Throws:

StreamException

updateActivities

public java8.util.concurrent.CompletableFuture<java.lang.Void> updateActivities(Token token,
                                                                                Activity... activities)
                                                                         throws StreamException

Throws:

StreamException