import React from 'react';
import connect from 'react-rxjs-connect';
 
import unreadMessages from '../observables/unread-messages';
 
class MessageCounter extends React.Component {
    render() {
        return <div className='message-counter'>
            { this.props.count }
        </div>;
    }
}
 
export default connect(MessageCounter, {
    count: unreadMessages.map(messages => messages.length)
});

const ConnectedComponent = connect(Component, { propName: observable });