Lean
$LEAN_TAG$
DataChannelProvider.cs
1
/*
2
* QUANTCONNECT.COM - Democratizing Finance, Empowering Individuals.
3
* Lean Algorithmic Trading Engine v2.0. Copyright 2014 QuantConnect Corporation.
4
*
5
* Licensed under the Apache License, Version 2.0 (the "License");
6
* you may not use this file except in compliance with the License.
7
* You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
8
*
9
* Unless required by applicable law or agreed to in writing, software
10
* distributed under the License is distributed on an "AS IS" BASIS,
11
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12
* See the License for the specific language governing permissions and
13
* limitations under the License.
14
*/
15
16
using
System;
17
using
QuantConnect
.
Data
;
18
using
QuantConnect
.
Packets
;
19
using
QuantConnect
.
Interfaces
;
20
using
QuantConnect
.
Data
.
Market
;
21
using
QuantConnect
.
Data
.
Fundamental
;
22
using
QuantConnect
.
Data
.
UniverseSelection
;
23
24
namespace
QuantConnect.Lean.Engine.DataFeeds
25
{
26
/// <summary>
27
/// Specifies data channel settings
28
/// </summary>
29
public
class
DataChannelProvider
:
IDataChannelProvider
30
{
31
/// <summary>
32
/// Initializes the instance with an algorithm node packet
33
/// </summary>
34
/// <param name="packet">Algorithm node packet</param>
35
public
virtual
void
Initialize
(
AlgorithmNodePacket
packet)
36
{
37
}
38
39
/// <summary>
40
/// True if this subscription request should be streamed
41
/// </summary>
42
public
virtual
bool
ShouldStreamSubscription
(
SubscriptionDataConfig
config)
43
{
44
return
IsStreamingType
(config) || !config.
IsCustomData
&& config.
Type
!= typeof(
CoarseFundamental
) && config.
Type
!= typeof(
Fundamental
) && config.
Type
!= typeof(
MarginInterestRate
);
45
}
46
47
/// <summary>
48
/// Returns true if the data type for the given subscription configuration supports streaming
49
/// </summary>
50
protected
static
bool
IsStreamingType
(
SubscriptionDataConfig
configuration)
51
{
52
var dataTypeInstance = configuration.
Type
.GetBaseDataInstance();
53
var source = dataTypeInstance.GetSource(configuration, DateTime.UtcNow,
true
);
54
return
source !=
null
&& source.TransportMedium ==
SubscriptionTransportMedium
.Streaming;
55
}
56
}
57
}
Engine
DataFeeds
DataChannelProvider.cs
Generated by
1.8.17