Page Menu
Home
Sealhub
Search
Configure Global Search
Log In
Files
F7188741
PhutilChannelChannel.php
No One
Temporary
Actions
Download File
Edit File
Delete File
View Transforms
Subscribe
Mute Notifications
Award Token
Flag For Later
Size
2 KB
Referenced Files
None
Subscribers
None
PhutilChannelChannel.php
View Options
<?php
/**
* Channel that wraps some other channel. This class is not interesting on its
* own and just serves as a no-op proxy, but extending it allows you to compose
* channels to mutate their characteristics (for instance, to add protocol
* semantics with @{class:PhutilProtocolChannel}).
*
* The implementation of this class is entirely uninteresting.
*/
abstract
class
PhutilChannelChannel
extends
PhutilChannel
{
private
$channel
;
public
function
__construct
(
PhutilChannel
$channel
)
{
parent
::
__construct
();
$this
->
channel
=
$channel
;
$this
->
didConstruct
();
}
protected
function
didConstruct
()
{
// Hook for subclasses.
}
public
function
read
()
{
return
$this
->
channel
->
read
();
}
public
function
write
(
$message
)
{
$this
->
channel
->
write
(
$message
);
return
$this
;
}
public
function
update
()
{
return
$this
->
channel
->
update
();
}
public
function
isOpen
()
{
return
$this
->
channel
->
isOpen
();
}
public
function
closeWriteChannel
()
{
return
$this
->
channel
->
closeWriteChannel
();
}
public
function
isOpenForReading
()
{
return
$this
->
channel
->
isOpenForReading
();
}
public
function
isOpenForWriting
()
{
return
$this
->
channel
->
isOpenForWriting
();
}
protected
function
readBytes
(
$length
)
{
$this
->
throwOnRawByteOperations
();
}
protected
function
writeBytes
(
$bytes
)
{
$this
->
throwOnRawByteOperations
();
}
protected
function
getReadSockets
()
{
return
$this
->
channel
->
getReadSockets
();
}
protected
function
getWriteSockets
()
{
return
$this
->
channel
->
getWriteSockets
();
}
public
function
setReadBufferSize
(
$size
)
{
$this
->
channel
->
setReadBufferSize
(
$size
);
return
$this
;
}
public
function
isReadBufferEmpty
()
{
return
$this
->
channel
->
isReadBufferEmpty
();
}
public
function
isWriteBufferEmpty
()
{
return
$this
->
channel
->
isWriteBufferEmpty
();
}
public
function
getWriteBufferSize
()
{
return
$this
->
channel
->
getWriteBufferSize
();
}
public
function
flush
()
{
$this
->
channel
->
flush
();
return
$this
;
}
protected
function
getUnderlyingChannel
()
{
return
$this
->
channel
;
}
private
function
throwOnRawByteOperations
()
{
// NOTE: You should only be able to end up here if you subclass this class
// and implement your subclass incorrectly, since the byte methods are
// protected.
throw
new
Exception
(
pht
(
'Do not call %s or %s directly on a %s. Instead, call %s or %s.'
,
'readBytes()'
,
'writeBytes()'
,
__CLASS__
,
'read()'
,
'write()'
));
}
}
File Metadata
Details
Attached
Mime Type
text/x-php
Expires
Tue, Jul 8, 08:30 (13 h, 6 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
729894
Default Alt Text
PhutilChannelChannel.php (2 KB)
Attached To
Mode
R118 Arcanist - fork
Attached
Detach File
Event Timeline
Log In to Comment