Valentin Shergin 94d49e544d Fabric: Codemod: All <fabric/... includes were renamed to <react/...
Summary: We are moving to more stable APIs removing all mentiones of the effort name from the codebase.

Reviewed By: mdvacca

Differential Revision: D12912894

fbshipit-source-id: 4a0c6b9e7454b8b14e62d419e9e9311dc0c56e7a
2018-11-10 14:22:15 -08:00

49 lines
1.1 KiB
C++

/**
* Copyright (c) Facebook, Inc. and its affiliates.
*
* This source code is licensed under the MIT license found in the
* LICENSE file in the root directory of this source tree.
*/
#pragma once
#include <memory>
#include <mutex>
#include <vector>
#include <jsi/jsi.h>
#include <react/events/EventBeat.h>
#include <react/events/RawEvent.h>
#include <react/events/primitives.h>
namespace facebook {
namespace react {
/*
* Event Queue synchronized with given Event Beat and dispatching event
* using given Event Pipe.
*/
class EventQueue {
public:
EventQueue(EventPipe eventPipe, std::unique_ptr<EventBeat> eventBeat);
virtual ~EventQueue() = default;
/*
* Enqueues and (probably later) dispatch a given event.
* Can be called on any thread.
*/
virtual void enqueueEvent(const RawEvent &rawEvent) const;
protected:
void onBeat(jsi::Runtime &runtime) const;
const EventPipe eventPipe_;
const std::unique_ptr<EventBeat> eventBeat_;
// Thread-safe, protected by `queueMutex_`.
mutable std::vector<RawEvent> queue_;
mutable std::mutex queueMutex_;
};
} // namespace react
} // namespace facebook