Class MultiPartByteRanges.PathContentSource
- All Implemented Interfaces:
Content.Source
- Enclosing class:
- MultiPartByteRanges
A specialized Content.Source
whose Path
content is sliced by a byte range.
-
Constructor Summary
ConstructorDescriptionPathContentSource
(Path path, ByteRange byteRange) Deprecated, for removal: This API element is subject to removal in a future version. -
Method Summary
Modifier and TypeMethodDescriptionvoid
Deprecated, for removal: This API element is subject to removal in a future version.Demands to invoke the given demand callback parameter when a chunk of content is available.void
Deprecated, for removal: This API element is subject to removal in a future version.Fails this content source with alast
failure chunk
, failing and discarding accumulated content chunks that were not yet read.void
Deprecated, for removal: This API element is subject to removal in a future version.Fails this content source with afailure chunk
that may or not may belast
.long
Deprecated, for removal: This API element is subject to removal in a future version.read()
Deprecated, for removal: This API element is subject to removal in a future version.Reads a chunk of content.boolean
rewind()
Deprecated, for removal: This API element is subject to removal in a future version.Rewinds this content, if possible, so that subsequent reads return chunks starting from the beginning of this content.
-
Constructor Details
-
PathContentSource
Deprecated, for removal: This API element is subject to removal in a future version.
-
-
Method Details
-
demand
Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:Content.Source
Demands to invoke the given demand callback parameter when a chunk of content is available.
See how to use this method idiomatically.
Implementations guarantee that calls to this method are safely reentrant so that stack overflows are avoided in the case of mutual recursion between the execution of the
Runnable
callback and a call to this method. Invocations of the passedRunnable
are serialized and a callback fordemand
call is not invoked until any previousdemand
callback has returned. Thus theRunnable
should not block waiting for a callback of a future demand call.The demand callback may be invoked spuriously: a subsequent call to
Content.Source.read()
may returnnull
.Calling this method establishes a pending demand, which is fulfilled when the demand callback is invoked.
Calling this method when there is already a pending demand results in an
IllegalStateException
to be thrown.If the invocation of the demand callback throws an exception, then
Content.Source.fail(Throwable)
is called.- Specified by:
demand
in interfaceContent.Source
- Parameters:
demandCallback
- the demand callback to invoke where there is a content chunk available- See Also:
-
fail
Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:Content.Source
Fails this content source with a
last
failure chunk
, failing and discarding accumulated content chunks that were not yet read.The failure may be notified to the content reader at a later time, when the content reader reads a content chunk, via a
Content.Chunk
instance with a non nullContent.Chunk.getFailure()
.If
Content.Source.read()
has returned a last chunk, this is a no operation.Typical failure: the content being aborted by user code, or idle timeouts.
If this method has already been called, then it is a no operation.
- Specified by:
fail
in interfaceContent.Source
- Parameters:
failure
- the cause of the failure- See Also:
-
fail
Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:Content.Source
Fails this content source with a
failure chunk
that may or not may belast
. Iflast
istrue
, then the failure is persistent and a call to this method acts asContent.Source.fail(Throwable)
. Otherwise the failure is transient and afailure chunk
will beread
in order with content chunks, and subsequent calls toread
may produce other content.A
Content.Source
or itsreader
may treat a transient failure as persistent.- Specified by:
fail
in interfaceContent.Source
- Parameters:
failure
- A failure.last
- true if the failure is persistent, false if the failure is transient.- See Also:
-
getLength
public long getLength()Deprecated, for removal: This API element is subject to removal in a future version.- Specified by:
getLength
in interfaceContent.Source
- Returns:
- the content length, if known, or -1 if the content length is unknown
-
read
Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:Content.Source
Reads a chunk of content.
See how to use this method idiomatically.
The returned chunk could be:
null
, to signal that there isn't a chunk of content available- an
Content.Chunk
instance with non nullContent.Chunk.getFailure()
, to signal that there was a failure trying to produce a chunk of content, or that the content production has beenfailed
externally - a
Content.Chunk
instance, containing the chunk of content.
Once a read returns an
Content.Chunk
instance with non-nullContent.Chunk.getFailure()
then if the failure islast
further reads will continue to return the same failure chunk instance, otherwise furtherread()
operations may return different non-failure chunks.Once a read returns a
last chunk
, further reads will continue to return a last chunk (although the instance may be different).The content reader code must ultimately arrange for a call to
Retainable.release()
on the returnedContent.Chunk
.Additionally, prior to the ultimate call to
Retainable.release()
, the reader code may make additional calls toRetainable.retain()
, that must ultimately be matched by a correspondent number of calls toRetainable.release()
.Concurrent reads from different threads are not recommended, as they are inherently in a race condition.
Reads performed outside the invocation context of a
demand callback
are allowed. However, reads performed with a pending demand are inherently in a race condition (the thread that reads with the thread that invokes the demand callback).- Specified by:
read
in interfaceContent.Source
- Returns:
- a chunk of content, possibly a failure instance, or
null
- See Also:
-
rewind
public boolean rewind()Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:Content.Source
Rewinds this content, if possible, so that subsequent reads return chunks starting from the beginning of this content.
- Specified by:
rewind
in interfaceContent.Source
- Returns:
- true if this content has been rewound, false if this content cannot be rewound
-
Content.Source.from(ByteBufferPool.Sized, Path, long, long)