3#include "mc/_HeaderOutputPredefine.h"
6#include "mc/deps/core/http/StatusCode.h"
7#include "mc/deps/core/threading/Async.h"
8#include "mc/deps/core/threading/AsyncPromise.h"
14namespace Bedrock::Http {
class HeaderCollection; }
17namespace Bedrock::Http {
19class WebSocket :
public ::std::enable_shared_from_this<::Bedrock::Http::WebSocket> {
41 virtual ::Bedrock::Threading::Async<::std::error_code> send(::std::string
const& message)
const;
44 virtual void onMessage(::std::string_view);
47 virtual void onBinaryMessage(::gsl::span<uchar const>);
50 virtual void onClose(uint);
56 MCNAPI ::HC_WEBSOCKET_OBSERVER*
_allocateSocket(::std::future<void> connectCompleted);
58 MCNAPI ::Bedrock::Threading::Async<::nonstd::expected<::Bedrock::Http::StatusCode, ::std::error_code>>
69 ::std::weak_ptr<::Bedrock::Http::WebSocket> weakThis,
79 MCNAPI ::Bedrock::Threading::Async<::std::error_code>
$send(::std::string
const& message)
const;
Definition WebSocket.h:19
static MCAPI void ** $vftable()
MCAPI ::Bedrock::Threading::Async<::std::error_code > $send(::std::string const &message) const
static MCAPI void _onConnect(::XAsyncBlock *asyncConnect, ::std::weak_ptr<::Bedrock::Http::WebSocket > weakThis, ::Bedrock::Threading::AsyncPromise<::nonstd::expected<::Bedrock::Http::StatusCode, ::std::error_code > > onComplete, ::HC_WEBSOCKET_OBSERVER *connectHandle)
MCAPI::HC_WEBSOCKET_OBSERVER * _allocateSocket(::std::future< void > connectCompleted)
MCAPI void $onClose(uint)
MCAPI ::Bedrock::Threading::Async<::nonstd::expected<::Bedrock::Http::StatusCode, ::std::error_code > > connect(::std::string const &uri, ::Bedrock::Http::HeaderCollection const &headers)
MCAPI void $onBinaryMessage(::gsl::span< uchar const >)
static MCAPI void _deallocateSocketAsync(::HC_WEBSOCKET_OBSERVER *handle)
MCAPI void $onMessage(::std::string_view)
Definition AsyncPromise.h:8
Definition HC_WEBSOCKET_OBSERVER.h:14
Definition XAsyncBlock.h:10