mirror of
https://github.com/RGBCube/serenity
synced 2025-06-19 18:42:07 +00:00
LibCore+LibIMAP: Move Promise to LibCore
This makes Promise available without having to link LibIMAP.
This commit is contained in:
parent
e4f05a9046
commit
2eb93f2628
3 changed files with 59 additions and 43 deletions
55
Userland/Libraries/LibCore/Promise.h
Normal file
55
Userland/Libraries/LibCore/Promise.h
Normal file
|
@ -0,0 +1,55 @@
|
||||||
|
/*
|
||||||
|
* Copyright (c) 2021, Kyle Pereira <hey@xylepereira.me>
|
||||||
|
*
|
||||||
|
* SPDX-License-Identifier: BSD-2-Clause
|
||||||
|
*/
|
||||||
|
|
||||||
|
#pragma once
|
||||||
|
|
||||||
|
#include <LibCore/EventLoop.h>
|
||||||
|
#include <LibCore/Object.h>
|
||||||
|
|
||||||
|
namespace Core {
|
||||||
|
template<typename Result>
|
||||||
|
class Promise : public Object {
|
||||||
|
C_OBJECT(Promise);
|
||||||
|
|
||||||
|
private:
|
||||||
|
Optional<Result> m_pending;
|
||||||
|
|
||||||
|
public:
|
||||||
|
Function<void(Result&)> on_resolved;
|
||||||
|
|
||||||
|
void resolve(Result&& result)
|
||||||
|
{
|
||||||
|
m_pending = move(result);
|
||||||
|
if (on_resolved)
|
||||||
|
on_resolved(m_pending.value());
|
||||||
|
}
|
||||||
|
|
||||||
|
bool is_resolved()
|
||||||
|
{
|
||||||
|
return m_pending.has_value();
|
||||||
|
};
|
||||||
|
|
||||||
|
Result await()
|
||||||
|
{
|
||||||
|
while (!is_resolved()) {
|
||||||
|
Core::EventLoop::current().pump();
|
||||||
|
}
|
||||||
|
return m_pending.release_value();
|
||||||
|
}
|
||||||
|
|
||||||
|
// Converts a Promise<A> to a Promise<B> using a function func: A -> B
|
||||||
|
template<typename T>
|
||||||
|
RefPtr<Promise<T>> map(T func(Result&))
|
||||||
|
{
|
||||||
|
RefPtr<Promise<T>> new_promise = Promise<T>::construct();
|
||||||
|
on_resolved = [new_promise, func](Result& result) mutable {
|
||||||
|
auto t = func(result);
|
||||||
|
new_promise->resolve(move(t));
|
||||||
|
};
|
||||||
|
return new_promise;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
}
|
|
@ -7,10 +7,14 @@
|
||||||
#pragma once
|
#pragma once
|
||||||
|
|
||||||
#include <AK/Function.h>
|
#include <AK/Function.h>
|
||||||
|
#include <LibCore/Promise.h>
|
||||||
#include <LibIMAP/Parser.h>
|
#include <LibIMAP/Parser.h>
|
||||||
#include <LibTLS/TLSv12.h>
|
#include <LibTLS/TLSv12.h>
|
||||||
|
|
||||||
namespace IMAP {
|
namespace IMAP {
|
||||||
|
template<typename T>
|
||||||
|
using Promise = Core::Promise<T>;
|
||||||
|
|
||||||
class Client {
|
class Client {
|
||||||
friend class Parser;
|
friend class Parser;
|
||||||
|
|
||||||
|
|
|
@ -11,7 +11,6 @@
|
||||||
#include <AK/Tuple.h>
|
#include <AK/Tuple.h>
|
||||||
#include <AK/Variant.h>
|
#include <AK/Variant.h>
|
||||||
#include <LibCore/DateTime.h>
|
#include <LibCore/DateTime.h>
|
||||||
#include <LibCore/EventLoop.h>
|
|
||||||
#include <LibCore/Object.h>
|
#include <LibCore/Object.h>
|
||||||
#include <utility>
|
#include <utility>
|
||||||
|
|
||||||
|
@ -762,48 +761,6 @@ struct ContinueRequest {
|
||||||
String data;
|
String data;
|
||||||
};
|
};
|
||||||
|
|
||||||
template<typename Result>
|
|
||||||
class Promise : public Core::Object {
|
|
||||||
C_OBJECT(Promise);
|
|
||||||
|
|
||||||
private:
|
|
||||||
Optional<Result> m_pending;
|
|
||||||
|
|
||||||
public:
|
|
||||||
Function<void(Result&)> on_resolved;
|
|
||||||
|
|
||||||
void resolve(Result&& result)
|
|
||||||
{
|
|
||||||
m_pending = move(result);
|
|
||||||
if (on_resolved)
|
|
||||||
on_resolved(m_pending.value());
|
|
||||||
}
|
|
||||||
|
|
||||||
bool is_resolved()
|
|
||||||
{
|
|
||||||
return m_pending.has_value();
|
|
||||||
};
|
|
||||||
|
|
||||||
Result await()
|
|
||||||
{
|
|
||||||
while (!is_resolved()) {
|
|
||||||
Core::EventLoop::current().pump();
|
|
||||||
}
|
|
||||||
return m_pending.release_value();
|
|
||||||
}
|
|
||||||
|
|
||||||
// Converts a Promise<A> to a Promise<B> using a function func: A -> B
|
|
||||||
template<typename T>
|
|
||||||
RefPtr<Promise<T>> map(T func(Result&))
|
|
||||||
{
|
|
||||||
RefPtr<Promise<T>> new_promise = Promise<T>::construct();
|
|
||||||
on_resolved = [new_promise, func](Result& result) mutable {
|
|
||||||
auto t = func(result);
|
|
||||||
new_promise->resolve(move(t));
|
|
||||||
};
|
|
||||||
return new_promise;
|
|
||||||
}
|
|
||||||
};
|
|
||||||
using Response = Variant<SolidResponse, ContinueRequest>;
|
using Response = Variant<SolidResponse, ContinueRequest>;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue