Modifier and Type | Method and Description |
---|---|
Stream |
IAddressBooksMgmt.backup(java.lang.String abUid,
java.lang.Long since) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<Stream> |
IAddressBooksMgmtPromise.backup(java.lang.String containerUid,
java.lang.Long since) |
Modifier and Type | Method and Description |
---|---|
void |
IAddressBooksMgmt.restore(java.lang.String abUid,
Stream restoreStream,
boolean resetBeforeRestore) |
java.util.concurrent.CompletableFuture<java.lang.Void> |
IAddressBooksMgmtPromise.restore(java.lang.String containerUid,
Stream restoreStream,
boolean reset) |
void |
IAddressBooksMgmtAsync.restore(java.lang.String containerUid,
Stream restoreStream,
boolean reset,
AsyncHandler<java.lang.Void> handler) |
Modifier and Type | Method and Description |
---|---|
void |
IAddressBooksMgmtAsync.backup(java.lang.String containerUid,
java.lang.Long since,
AsyncHandler<Stream> handler) |
Modifier and Type | Method and Description |
---|---|
Stream |
AddressBooksMgmt.backup(java.lang.String abUid,
java.lang.Long since) |
Modifier and Type | Method and Description |
---|---|
void |
AddressBooksMgmt.restore(java.lang.String abUid,
Stream restoreStream,
boolean resetBeforeRestore) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<AttachedFile> |
IAttachmentPromise.share(java.lang.String name,
Stream document) |
AttachedFile |
IAttachment.share(java.lang.String name,
Stream document)
Share a mail attachment
|
void |
IAttachmentAsync.share(java.lang.String name,
Stream document,
AsyncHandler<AttachedFile> handler) |
java.util.concurrent.CompletableFuture<AttachedFile> |
IAttachmentPromise.shareDedup(java.lang.String extension,
Stream document) |
AttachedFile |
IAttachment.shareDedup(java.lang.String extension,
Stream document)
Share a mail attachment.
|
void |
IAttachmentAsync.shareDedup(java.lang.String extension,
Stream document,
AsyncHandler<AttachedFile> handler) |
Modifier and Type | Method and Description |
---|---|
AttachedFile |
AttachmentService.share(java.lang.String name,
Stream document) |
AttachedFile |
AttachmentService.shareDedup(java.lang.String extension,
Stream document) |
Modifier and Type | Method and Description |
---|---|
Stream |
StorageApiLink.stream(java.nio.file.Path p) |
Modifier and Type | Method and Description |
---|---|
Stream |
CoreStorageBackend.stream(java.nio.file.Path p) |
Modifier and Type | Method and Description |
---|---|
Stream |
MockReplicationStorage.stream(java.nio.file.Path p) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<java.lang.Void> |
MockMessageBodiesPromise.create(java.lang.String uid,
Stream eml) |
Modifier and Type | Method and Description |
---|---|
Stream |
IMailboxItems.fetch(long imapUid,
java.lang.String address,
java.lang.String encoding,
java.lang.String mime,
java.lang.String charset,
java.lang.String filename)
Fetch a single part from an email mime tree.
|
Stream |
IMailboxItems.fetchComplete(long imapUid) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<Stream> |
IMailboxItemsPromise.fetch(long imapUid,
java.lang.String address,
java.lang.String encoding,
java.lang.String mime,
java.lang.String charset,
java.lang.String filename) |
java.util.concurrent.CompletableFuture<Stream> |
IMailboxItemsPromise.fetchComplete(long imapUid) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<java.lang.String> |
IMailboxItemsPromise.uploadPart(Stream part) |
java.lang.String |
IMailboxItems.uploadPart(Stream part)
Upload an email part (eg.
|
void |
IMailboxItemsAsync.uploadPart(Stream part,
AsyncHandler<java.lang.String> handler) |
Modifier and Type | Method and Description |
---|---|
void |
IMailboxItemsAsync.fetch(long imapUid,
java.lang.String address,
java.lang.String encoding,
java.lang.String mime,
java.lang.String charset,
java.lang.String filename,
AsyncHandler<Stream> handler) |
void |
IMailboxItemsAsync.fetchComplete(long imapUid,
AsyncHandler<Stream> handler) |
Modifier and Type | Method and Description |
---|---|
static <T> java.util.concurrent.CompletableFuture<T> |
EZInputStreamAdapter.consume(Stream stream,
java.util.function.Function<com.google.common.io.CountingInputStream,T> streamConsumer)
Provides an InputStream from a bluemind
Stream . |
static java.util.concurrent.CompletableFuture<BodyStreamProcessor.MessageBodyData> |
BodyStreamProcessor.processBody(Stream eml) |
Modifier and Type | Method and Description |
---|---|
Stream |
IDbMailboxRecords.fetchComplete(long imapUid) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<Stream> |
IDbMailboxRecordsPromise.fetchComplete(long imapUid) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<java.lang.Void> |
IDbMessageBodiesPromise.create(java.lang.String uid,
Stream eml) |
void |
IDbMessageBodies.create(java.lang.String uid,
Stream eml) |
void |
IDbMessageBodiesAsync.create(java.lang.String uid,
Stream eml,
AsyncHandler<java.lang.Void> handler) |
Modifier and Type | Method and Description |
---|---|
void |
IDbMailboxRecordsAsync.fetchComplete(long imapUid,
AsyncHandler<Stream> handler) |
Modifier and Type | Method and Description |
---|---|
static IndexedMessageBody |
IndexedMessageBody.createIndexBody(java.lang.String uid,
Stream eml) |
Modifier and Type | Method and Description |
---|---|
Stream |
ImapMailboxRecordsService.fetch(long imapUid,
java.lang.String address,
java.lang.String encoding,
java.lang.String mime,
java.lang.String charset,
java.lang.String filename) |
Stream |
NoopMailboxRecordService.fetchComplete(long imapUid) |
Stream |
ImapMailboxRecordsService.fetchComplete(long imapUid) |
Stream |
BaseMailboxRecordsService.fetchComplete(long imapUid) |
Modifier and Type | Method and Description |
---|---|
void |
DbMessageBodiesService.create(java.lang.String uid,
Stream eml) |
static java.util.concurrent.CompletableFuture<io.netty.buffer.ByteBuf> |
SyncStreamDownload.read(Stream s) |
java.lang.String |
ImapMailboxRecordsService.uploadPart(Stream part) |
Modifier and Type | Method and Description |
---|---|
protected Stream |
BodyStreamProcessorTests.openResource(java.lang.String path) |
protected Stream |
AbstractMessageBodiesServiceTests.openResource(java.lang.String path) |
Modifier and Type | Method and Description |
---|---|
Stream |
IVEvent.exportAll()
Exports all the
VEvent of the container |
Stream |
IPublishCalendar.publish(java.lang.String token) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<Stream> |
IVEventPromise.exportAll() |
java.util.concurrent.CompletableFuture<Stream> |
IPublishCalendarPromise.publish(java.lang.String token) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<TaskRef> |
IVEventPromise.importIcs(Stream ics) |
TaskRef |
IVEvent.importIcs(Stream ics)
Imports an ICS
|
void |
IVEventAsync.importIcs(Stream ics,
AsyncHandler<TaskRef> handler) |
Modifier and Type | Method and Description |
---|---|
void |
IVEventAsync.exportAll(AsyncHandler<Stream> handler) |
void |
IPublishCalendarAsync.publish(java.lang.String token,
AsyncHandler<Stream> handler) |
Modifier and Type | Method and Description |
---|---|
Stream |
VEventService.exportAll() |
Stream |
PublishCalendarService.publish(java.lang.String token) |
Modifier and Type | Method and Description |
---|---|
TaskRef |
VEventService.importIcs(Stream stream) |
Modifier and Type | Method and Description |
---|---|
Stream |
CliUtils.getStreamFromFile(java.nio.file.Path path) |
Stream |
CliUtils.getStreamFromFile(java.lang.String filename) |
Modifier and Type | Method and Description |
---|---|
static <T> Stream |
GenericStream.simpleValue(T value,
java.util.function.Function<T,byte[]> toByteArray) |
Modifier and Type | Method and Description |
---|---|
static <T> java.util.concurrent.CompletableFuture<io.vertx.core.buffer.Buffer> |
GenericStream.asyncStreamToBuffer(Stream stream) |
static java.util.concurrent.CompletableFuture<java.lang.Void> |
GenericStream.slowRead(Stream stream) |
static <T> void |
GenericStream.streamToFile(Stream stream,
java.io.File file) |
static <T> void |
GenericStream.streamToFile(Stream stream,
java.io.File file,
java.nio.file.StandardOpenOption... opts) |
static java.lang.String |
GenericStream.streamToString(Stream stream) |
Modifier and Type | Method and Description |
---|---|
Stream |
DefaultResponseCodecs.StreamResponseCodec.decode(RestResponse response) |
Stream |
DefaultBodyParameterCodecs.StreamBodyCodec.parse(RestRequest request) |
Modifier and Type | Method and Description |
---|---|
RestResponse |
DefaultResponseCodecs.StreamResponseCodec.encode(RestRequest request,
java.lang.String defaultMimeType,
Stream response) |
void |
DefaultBodyParameterCodecs.StreamBodyCodec.encode(Stream object,
RestRequest request) |
Modifier and Type | Method and Description |
---|---|
Stream |
RestStreamImpl.in() |
Stream |
IRestStreamTestService.in() |
Stream |
RestStreamImpl.inContentType(java.lang.String mime,
java.lang.String cs,
java.lang.String name) |
Stream |
IRestStreamTestService.inContentType(java.lang.String mime,
java.lang.String cs,
java.lang.String fileName) |
Stream |
RestStreamImpl.inout(Stream stream) |
Stream |
IRestStreamTestService.inout(Stream stream) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<Stream> |
IRestStreamTestServicePromise.in() |
java.util.concurrent.CompletableFuture<Stream> |
IRestStreamTestServicePromise.inContentType(java.lang.String mime,
java.lang.String cs,
java.lang.String fn) |
java.util.concurrent.CompletableFuture<Stream> |
IRestStreamTestServicePromise.inout(Stream stream) |
Modifier and Type | Method and Description |
---|---|
Stream |
RestStreamImpl.inout(Stream stream) |
java.util.concurrent.CompletableFuture<Stream> |
IRestStreamTestServicePromise.inout(Stream stream) |
Stream |
IRestStreamTestService.inout(Stream stream) |
void |
IRestStreamTestServiceAsync.inout(Stream stream,
AsyncHandler<Stream> handler) |
java.lang.String |
RestStreamImpl.notTimeout(Stream stream) |
java.util.concurrent.CompletableFuture<java.lang.String> |
IRestStreamTestServicePromise.notTimeout(Stream stream) |
java.lang.String |
IRestStreamTestService.notTimeout(Stream stream) |
void |
IRestStreamTestServiceAsync.notTimeout(Stream stream,
AsyncHandler<java.lang.String> handler) |
java.lang.String |
RestStreamImpl.out(Stream stream) |
java.util.concurrent.CompletableFuture<java.lang.String> |
IRestStreamTestServicePromise.out(Stream stream) |
java.lang.String |
IRestStreamTestService.out(Stream stream) |
void |
IRestStreamTestServiceAsync.out(Stream stream,
AsyncHandler<java.lang.String> handler) |
Modifier and Type | Method and Description |
---|---|
void |
IRestStreamTestServiceAsync.in(AsyncHandler<Stream> handler) |
void |
IRestStreamTestServiceAsync.inContentType(java.lang.String mime,
java.lang.String cs,
java.lang.String fn,
AsyncHandler<Stream> handler) |
void |
IRestStreamTestServiceAsync.inout(Stream stream,
AsyncHandler<Stream> handler) |
Modifier and Type | Class and Description |
---|---|
static class |
VertxStream.LocalPathStream |
static class |
VertxStream.ReadStreamStream |
class |
VertxStreamConsumer |
class |
VertxStreamProducer |
Modifier and Type | Method and Description |
---|---|
static Stream |
VertxStream.localPath(java.nio.file.Path p) |
static Stream |
VertxStream.stream(io.vertx.core.buffer.Buffer body) |
static Stream |
VertxStream.stream(io.vertx.core.buffer.Buffer body,
java.lang.String mime,
java.lang.String charset) |
static Stream |
VertxStream.stream(io.vertx.core.buffer.Buffer body,
java.lang.String mime,
java.lang.String charset,
java.lang.String fileName) |
static Stream |
VertxStream.stream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream) |
static Stream |
VertxStream.stream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream,
java.lang.String mime,
java.lang.String charset,
java.lang.String fileName) |
Modifier and Type | Method and Description |
---|---|
static <T> io.vertx.core.streams.ReadStream<T> |
VertxStream.read(Stream stream) |
static <T> io.vertx.core.streams.ReadStream<T> |
VertxStream.readInContext(io.vertx.core.Vertx vertx,
Stream stream) |
static java.util.concurrent.CompletableFuture<java.lang.Void> |
VertxStream.sink(Stream stream) |
Modifier and Type | Method and Description |
---|---|
Stream |
ITask.log()
retrieve task log (open until task end)
|
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<Stream> |
ITaskPromise.log() |
Modifier and Type | Method and Description |
---|---|
void |
ITaskAsync.log(AsyncHandler<Stream> handler) |
Modifier and Type | Class and Description |
---|---|
class |
LogStream |
Modifier and Type | Method and Description |
---|---|
Stream |
TaskService.log() |
Modifier and Type | Method and Description |
---|---|
java.io.InputStream |
BodyMailLoader.toInputStream(Stream stream) |
Modifier and Type | Method and Description |
---|---|
void |
BodyAccumulator.consumeBodyPart(MessageBody.Part bodyPart,
Stream stream) |
void |
BodyAccumulator.consumeMime(Stream stream) |
static java.util.concurrent.CompletableFuture<io.vertx.core.buffer.Buffer> |
SyncStreamDownload.read(Stream s) |
static java.util.concurrent.CompletableFuture<java.lang.Void> |
SyncStreamDownload.read(Stream s,
java.io.OutputStream target) |
io.netty.buffer.ByteBuf |
BodyAccumulator.toByteBuf(Stream stream) |
Modifier and Type | Method and Description |
---|---|
Stream |
IFileHosting.get(java.lang.String path)
Retrieves a document from the file hosting repository
|
Stream |
IFileHosting.getSharedFile(java.lang.String uid)
Retrieves a document from the file hosting repository by its public uid
|
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<Stream> |
IFileHostingPromise.get(java.lang.String path) |
java.util.concurrent.CompletableFuture<Stream> |
IFileHostingPromise.getSharedFile(java.lang.String uid) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<java.lang.Void> |
IFileHostingPromise.store(java.lang.String path,
Stream document) |
void |
IFileHosting.store(java.lang.String path,
Stream document)
Update/insert a document
|
void |
IFileHostingAsync.store(java.lang.String path,
Stream document,
AsyncHandler<java.lang.Void> handler) |
Modifier and Type | Method and Description |
---|---|
void |
IFileHostingAsync.get(java.lang.String path,
AsyncHandler<Stream> handler) |
void |
IFileHostingAsync.getSharedFile(java.lang.String uid,
AsyncHandler<Stream> handler) |
Modifier and Type | Method and Description |
---|---|
Stream |
FileSystemFileHostingService.get(SecurityContext context,
java.lang.String path) |
Stream |
FileSystemFileHostingService.getSharedFile(SecurityContext context,
java.lang.String uid) |
Modifier and Type | Method and Description |
---|---|
void |
FileSystemFileHostingService.store(SecurityContext context,
java.lang.String path,
Stream document) |
Modifier and Type | Method and Description |
---|---|
Stream |
IFileHostingService.get(SecurityContext context,
java.lang.String path)
Retrieves a document from the file hosting repository
|
Stream |
IFileHostingService.getSharedFile(SecurityContext context,
java.lang.String uid)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
IFileHostingService.store(SecurityContext context,
java.lang.String path,
Stream document)
Update/insert a document
|
Modifier and Type | Method and Description |
---|---|
Stream |
FileHostingService.get(java.lang.String path) |
Stream |
FileHostingService.getSharedFile(java.lang.String uid) |
Modifier and Type | Method and Description |
---|---|
void |
FileHostingService.store(java.lang.String path,
Stream document) |
Modifier and Type | Method and Description |
---|---|
Stream |
WebDavFileHostingService.get(SecurityContext context,
java.lang.String path) |
Stream |
WebDavFileHostingService.getSharedFile(SecurityContext context,
java.lang.String uid) |
Modifier and Type | Method and Description |
---|---|
void |
WebDavFileHostingService.store(SecurityContext context,
java.lang.String path,
Stream document) |
Modifier and Type | Method and Description |
---|---|
void |
IAlerts.receive(Stream alertPayload)
Send an alert.
|
java.util.concurrent.CompletableFuture<java.lang.Void> |
IAlertsPromise.receive(Stream alertPayload) |
void |
IAlertsAsync.receive(Stream alertPayload,
AsyncHandler<java.lang.Void> handler) |
Modifier and Type | Method and Description |
---|---|
void |
AlertsService.receive(Stream payload) |
Modifier and Type | Method and Description |
---|---|
void |
IInstallation.updateSubscriptionWithArchive(Stream archive) |
java.util.concurrent.CompletableFuture<java.lang.Void> |
IInstallationPromise.updateSubscriptionWithArchive(Stream archive) |
void |
IInstallationAsync.updateSubscriptionWithArchive(Stream archive,
AsyncHandler<java.lang.Void> handler) |
Modifier and Type | Method and Description |
---|---|
void |
InstallationService.updateSubscriptionWithArchive(Stream archive) |
Modifier and Type | Method and Description |
---|---|
Stream |
IVTodo.exportAll()
Export all
VTodo from a todolist as iCalendar VTodo objects. |
Stream |
IVTodo.exportTodos(java.util.List<java.lang.String> uids)
Export a list of
VTodo as iCalendar VTodo objects |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<Stream> |
IVTodoPromise.exportAll() |
java.util.concurrent.CompletableFuture<Stream> |
IVTodoPromise.exportTodos(java.util.List<java.lang.String> uids) |
Modifier and Type | Method and Description |
---|---|
void |
IVTodoAsync.exportAll(AsyncHandler<Stream> handler) |
void |
IVTodoAsync.exportTodos(java.util.List<java.lang.String> uids,
AsyncHandler<Stream> handler) |
Modifier and Type | Method and Description |
---|---|
Stream |
VTodoService.exportAll() |
Stream |
VTodoService.exportTodos(java.util.List<java.lang.String> uids) |
Copyright © 2021. All Rights Reserved.